{"repo":"ballerina-platform/module-ballerinax-kafka","free":true,"listed":false,"github":"https://github.com/ballerina-platform/module-ballerinax-kafka","clone":"git clone https://github.com/ballerina-platform/module-ballerinax-kafka.git","description":"Ballerina Kafka Module.","language":"Ballerina","stars":112,"topics":["ballerina","kafka","apache-kafka","messaging","ballerina-lang"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"Ballerina Kafka Library This library provides an implementation to interact with Kafka Brokers via Kafka Consumer and Kafka Producer clients. Apache Kafka is an open-source distributed event streaming platform used for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications. This library supports Kafka 1.x.x, 2.x.x and 3.x.x versions. Consumer and producer Kafka producer A Kafka producer is a Kafka client that publishes records to the Kafka cluster. The producer is thread-safe and sharing a single producer instance across threads will generally be faster than having multiple instances. When working with a Kafka producer, the first thing to do is to initialize the producer. For the producer to execute successfully, an active Kafka broker should be available. The code snippet given below initializes a producer with the basic configuration. Kafka consumer A Kafka consumer is a subscriber responsible for reading records from one or more topics and one or more partitions of a topic. When working with a Kafka consumer, the first thing to do is initialize the consumer. For the consumer to execute successfully, an active Kafka broker should be available. The code snippet given below initializes a consumer with the basic configuration. Listener The Kafka consumer can be used as a listener to a set of topics without the need to manually poll the messages. You can use the Caller to manually commit the offsets of the messages that are rea","default_branch":null,"files":null,"tree":[],"storefront":"/r/ballerina-platform","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/ballerina-platform/module-ballerinax-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."}