{"repo":"fede1024/rust-rdkafka","free":true,"listed":false,"github":"https://github.com/fede1024/rust-rdkafka","clone":"git clone https://github.com/fede1024/rust-rdkafka.git","description":"A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka","language":"Rust","stars":1993,"topics":["rust","kafka-client","librdkafka","kafka","futures"],"license":"MIT","category":"data-pipelines","readme_excerpt":"rust-rdkafka A fully asynchronous, [futures]-enabled [Apache Kafka] client library for Rust based on [librdkafka]. The library rust-rdkafka provides a safe Rust interface to librdkafka. This version is compatible with librdkafka v1.9.2+. Documentation - Current master branch - Latest release - Changelog Features The main features provided at the moment are: - Support for all Kafka versions since 0.8.x. For more information about broker compatibility options, check the [librdkafka documentation][broker-compat]. - Consume from single or multiple topics. - Automatic consumer rebalancing. - Customizable rebalance, with pre and post rebalance callbacks. - Synchronous or asynchronous message production. - Customizable offset commit. - Create and delete topics and add and edit partitions. - Alter broker and topic configurations. - Access to cluster metadata (list of topic-partitions, replicas, active brokers etc). - Access to group metadata (list groups, list members of groups, hostnames, etc.). - Access to producer and consumer metrics, errors and callbacks. - Exactly-once semantics (EOS) via idempotent and transactional producers and read-committed consumers. One million messages per second rust-rdkafka is designed to be easy and safe to use thanks to the abstraction layer written in Rust, while at the same time being extremely fast thanks to the librdkafka C library. Here are some benchmark results using the [ BaseProducer ], sending data to a single Kafka 0.11 process running in","default_branch":null,"files":null,"tree":[],"storefront":"/r/fede1024","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/fede1024/rust-rdkafka/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."}