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

ServiceNow
ServiceNow

Tasks that create, update, read, and delete ServiceNow records via REST.

DataBusiness

4 Tasks

Azure
Azure

Leverage Microsoft Azure services within Kestra data workflows.

CloudDataInfrastructure

47 Tasks

2 Blueprints

Graylog (EE)
Graylog
Enterprise

Export Kestra execution logs to Graylog via GELF HTTP input. Useful for centralized logging and SIEM integrations.

Infrastructure

1 Tasks
OVERVIEW
Versions
1.3.0
Latest
February 16, 2026 Release Notes Min. Compatible Kestra Version: 1.2.3
Previous Versions
1.2.0December 16, 2025 Min. Compatible Kestra Version: 1.0.0
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

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
DataInfrastructure
Links & Resources
GitHub