Apache KafkaApache Kafka
Apache KafkaCertified

Tasks that produce, consume, and trigger workflows from Apache Kafka topics.

Set bootstrap servers, topic names, and serializers along with security settings (SASL/SSL) to publish messages, poll or stream consumes, and use triggers to start flows on new records with offsets and consumer group controls.

tasks

Consume

Consume messages from one or more Kafka topics.

io.kestra.plugin.kafka.Consume
Produce

Send a message to a Kafka topic.

io.kestra.plugin.kafka.Produce

triggers

RealtimeTrigger

Trigger a flow on message consumption in real-time from a Kafka topic.

io.kestra.plugin.kafka.RealtimeTrigger
Trigger

Trigger a flow on message consumption periodically from Kafka topics.

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

Azure
Azure

Leverage Microsoft Azure services within Kestra data workflows.

CloudMessagingStorageBatchTool

37 Tasks

2 Blueprints

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

OVERVIEW
Versions
1.2.0
Latest
December 16, 2025 Release Notes Min. Compatible Kestra Version: 1.0.0
Previous Versions
1.1.0November 3, 2025 Min. Compatible Kestra Version: 1.0.0
1.0.1October 22, 2025 Min. Compatible Kestra Version: 1.0.0
1.0.0September 8, 2025 Min. Compatible Kestra Version: [1.0,)
0.24.0August 5, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0-rc1-SNAPSHOTJuly 31, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0-rc0-SNAPSHOTJuly 29, 2025 Min. Compatible Kestra Version: [0.24,)
0.23.0June 17, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc5-SNAPSHOTJune 16, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc4-SNAPSHOTJune 12, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc3-SNAPSHOTJune 10, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc2-SNAPSHOTJune 9, 2025 Min. Compatible Kestra Version: [0.20,)
0.23.0-rc1-SNAPSHOTJune 4, 2025 Min. Compatible Kestra Version: [0.20,)
0.23.0-rc0-SNAPSHOTJune 3, 2025 Min. Compatible Kestra Version: [0.20,)
0.22.0April 1, 2025 Min. Compatible Kestra Version: [0.20,)
0.22.0-rc4-SNAPSHOTMarch 31, 2025 Min. Compatible Kestra Version: [0.20,)
0.22.0-rc2-SNAPSHOTMarch 28, 2025 Min. Compatible Kestra Version: [0.20,)
0.22.0-rc1-SNAPSHOTMarch 25, 2025 Min. Compatible Kestra Version: [0.20,)
0.21.0February 4, 2025 Min. Compatible Kestra Version: [0.20,)
0.21.0-rc2-SNAPSHOTFebruary 3, 2025 Min. Compatible Kestra Version: [0.20,)
0.21.0-rc1-SNAPSHOTJanuary 31, 2025 Min. Compatible Kestra Version: [0.20,)
0.21.0-rc0-SNAPSHOTJanuary 29, 2025 Min. Compatible Kestra Version: [0.20,)
0.20.0December 3, 2024 Min. Compatible Kestra Version: [0.20,)
0.19.1October 15, 2024 Min. Compatible Kestra Version: [0.18,)
0.18.3October 15, 2024 Min. Compatible Kestra Version: [0.18,)
0.18.2October 4, 2024 Min. Compatible Kestra Version: [0.18,)
0.17.3October 3, 2024 Min. Compatible Kestra Version: [0.17,0.18)
0.19.0October 1, 2024 Min. Compatible Kestra Version: [0.18,)
0.17.2September 19, 2024 Min. Compatible Kestra Version: [0.17,0.18)
0.18.1September 5, 2024 Min. Compatible Kestra Version: [0.18,)

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
Messaging
Links & Resources
GitHub