Apache Kafka Apache Kafka
Apache Kafka Certified

tasks

Consume
io.kestra.plugin.kafka.Consume
Produce
io.kestra.plugin.kafka.Produce

triggers

RealtimeTrigger
io.kestra.plugin.kafka.RealtimeTrigger
Trigger
io.kestra.plugin.kafka.Trigger

Create automations with Kafka Plugins

Stream kestra audit logs from a Kafka topic to BigQuery for analytics and troubleshooting
Cloud
Extract data from a REST API and send it to a Kafka topic using the Kafka producer task
Data

More Plugins in this Category

Apache Pulsar
Apache Pulsar

Tasks that publish, consume, and trigger workflows with Apache Pulsar.

Messaging

5 Tasks

1 Blueprints

AMQP
AMQP

Tasks that connect to RabbitMQ brokers to declare exchanges and queues, bind routing keys, publish messages, and consume them via tasks or triggers (batch or real time).

Messaging

7 Tasks

1 Blueprints

NATS
NATS

Tasks that publish, subscribe, and work with NATS messaging.

Messaging

9 Tasks
OVERVIEW

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
Messaging
Links & Resources
GitHub