{"repo":"siddhi-io/siddhi-io-kafka","free":true,"listed":false,"github":"https://github.com/siddhi-io/siddhi-io-kafka","clone":"git clone https://github.com/siddhi-io/siddhi-io-kafka.git","description":"Extension that can be used to receive events from a Kafka cluster and to publish events to a Kafka cluster","language":"Java","stars":18,"topics":["siddhi","extension","io","kafka","message-queue"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"Siddhi IO Kafka ====================================== The siddhi-io-kafka extension is an extension to Siddhi that receives and publishes events from and to Kafka. For information on Siddhi and it's features refer Siddhi Documentation . Download Versions 5.x and above with group id io.siddhi.extension. from here . Versions 4.x and lower with group id org.wso2.extension.siddhi. from here . Latest API Docs Latest API Docs is 5.0.21 . Features kafka ( Sink ) A Kafka sink publishes events processed by WSO2 SP to a topic with a partition for a Kafka cluster. The events can be published in the TEXT XML JSON or Binary format. If the topic is not already created in the Kafka cluster, the Kafka sink creates the default partition for the given topic. The publishing topic and partition can be a dynamic value taken from the Siddhi event. To configure a sink to use the Kafka transport, the type parameter should have kafka as its value. kafka-replay-request ( Sink ) This sink is used to request replay of specific range of events on a specified partition of a topic. kafkaMultiDC ( Sink ) A Kafka sink publishes events processed by WSO2 SP to a topic with a partition for a Kafka cluster. The events can be published in the TEXT XML JSON or Binary format. If the topic is not already created in the Kafka cluster, the Kafka sink creates the default partition for the given topic. The publishing topic and partition can be a dynamic value taken from the Siddhi event. To configure a sink to publish ","default_branch":null,"files":null,"tree":[],"storefront":"/r/siddhi-io","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/siddhi-io/siddhi-io-kafka/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."}