Skip to content

kestra-io/plugin-kafka

Repository files navigation

Kestra workflow orchestrator

Event-Driven Declarative Orchestrator

Last Version License Github star
Kestra infinitely scalable orchestration and scheduling platform Slack

twitter linkedin youtube


Get started in 4 minutes with Kestra

Get started with Kestra in 4 minutes.

Kestra Kafka Plugin

Why

  • What user problem does this solve? Teams need to produce, consume, and trigger workflows from Apache Kafka topics, including share-group queue semantics from orchestrated workflows instead of relying on manual console work, ad hoc scripts, or disconnected schedulers.
  • Why would a team adopt this plugin in a workflow? It keeps Apache Kafka steps in the same Kestra flow as upstream preparation, approvals, retries, notifications, and downstream systems.
  • What operational/business outcome does it enable? It reduces manual handoffs and fragmented tooling while improving reliability, traceability, and delivery speed for processes that depend on Apache Kafka.

What

  • Provides plugin components under io.kestra.plugin.kafka.
  • Includes classes such as QueueAcknowledgeType, Message, Consume, Produce.

Documentation

License

Apache 2.0 © Kestra Technologies

Stay up to date

We release new versions every month. Give the main repository a star to stay up to date with the latest releases and get notified about future updates.

Star the repo

Packages

 
 
 

Contributors

Languages

Generated from kestra-io/plugin-template