{"repo":"camunda-community-hub/kafka-connect-zeebe","free":true,"listed":false,"github":"https://github.com/camunda-community-hub/kafka-connect-zeebe","clone":"git clone https://github.com/camunda-community-hub/kafka-connect-zeebe.git","description":"Kafka Connect for Zeebe.io","language":"Java","stars":99,"topics":["zeebe","kafka","kafka-connect","camunda-8"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":":warning: This is not the official Kafka connector for Camunda 8. The Kafka Producer and Kafka Consumer connectors are found here. This project uses Kafka Connect from Confluence. kafka-connect-zeebe This Kafka Connect connector for Zeebe can do two things: Send messages to a Kafka topic when a workflow instance reached a specific activity. Please note that a message is more precisely a kafka record , which is also often named event . This is a source in the Kafka Connect speak. Consume messages from a Kafka topic and correlate them to a workflow . This is a Kafka Connect sink . It can work with Camunda Platform 8 SaaS or self-managed. See this blog post for some background on the implementation. Examples and walk-through Examples The following video walks you through an example connecting to Camunda Platform 8 - SaaS: Installation and quickstart You will find information on how to build the connector and how to run Kafka and Zeebe to get started quickly here: Installation Connectors The plugin comes with two connectors, a source and a sink connector. The source connector activates Zeebe jobs, publishes them as Kafka records, and completes them once they have been committed to Kafka. Sink connector In a workflow model you can wait for certain events by name (extracted from the payload by messageNameJsonPath): The sink connector consumes Kafka records and publishes messages constructed from those records to Zeebe. This uses the Zeebe Message Correlation features. So for exampl","default_branch":null,"files":null,"tree":[],"storefront":"/r/camunda-community-hub","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/camunda-community-hub/kafka-connect-zeebe/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}