Kinesis

Kinesis

Certified

Tasks that write batches of records to Amazon Kinesis Data Streams with partition keys for high-throughput, real-time ingestion pipelines.

tasks

AbstractKinesis
io.kestra.plugin.aws.kinesis.AbstractKinesis
Consume
io.kestra.plugin.aws.kinesis.Consume
PutRecords
io.kestra.plugin.aws.kinesis.PutRecords

triggers

RealtimeTrigger
io.kestra.plugin.aws.kinesis.RealtimeTrigger
Trigger
io.kestra.plugin.aws.kinesis.Trigger

How to use this plugin

Create automations with AWS Kinesis

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

More Plugins in this Category

MongoDB
MongoDB

Tasks that query and manipulate MongoDB collections.

Data

8 tasks

3 blueprints

Transform
Transform

Transform typed records, variables, and Ion data.

CoreData

6 tasks