AWS Kinesis | Kestra

AWS Kinesis
Certified
Tasks and triggers for Amazon Kinesis Data Streams: write batches of records with partition keys, consume records, and start flows on new records via polling or realtime triggers.

tasks

Consume

Consume records from Kinesis

io.kestra.plugin.aws.kinesis.Consume

PutRecords

Put records to Kinesis Data Streams

io.kestra.plugin.aws.kinesis.PutRecords

triggers

RealtimeTrigger

Trigger on Kinesis records (realtime)

io.kestra.plugin.aws.kinesis.RealtimeTrigger

Trigger

Trigger on Kinesis records (polling)

io.kestra.plugin.aws.kinesis.Trigger

Stream JSON and Application Events to AWS Kinesis Data Streams at Scale

Liquibase

Tasks that run Liquibase change management commands.

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.