文件名称：rust-rdkafka：基于librdkafka的Rust的完全异步的，基于期货的Kafka客户端库
文件大小：149KB
文件格式：ZIP
更新时间：2024-02-26 09:23:29
rust kafka librdkafka kafka-client futures
锈-rdkafka 基于Rust的完全异步的，启用了客户端库。 图书馆 rust-rdkafka为rust-rdkafka提供了一个安全的Rust接口。 master分支当前基于librdkafka 1.5.3。 文献资料 产品特点 目前提供的主要功能是： 自0.8.x起支持所有Kafka版本。 有关代理兼容性选项的更多信息，请。 消耗单个或多个主题。 消费者自动重新平衡。 可自定义的重新平衡，带有预平衡和后平衡。 同步或异步消息生成。 可自定义的偏移量提交。 创建和删除主题以及添加和编辑分区。 更改代理和主题配置。 访问群集元数据（主题分区，副本，活动代理等的列表）。
【文件预览】：
rust-rdkafka-master
----.gitattributes(238B)
----Cargo.toml(2KB)
----.github()
--------workflows()
----.gitmodules(106B)
----src()
--------consumer()
--------message.rs(21KB)
--------error.rs(12KB)
--------client.rs(15KB)
--------metadata.rs(4KB)
--------config.rs(10KB)
--------util.rs(10KB)
--------topic_partition_list.rs(17KB)
--------statistics.rs(23KB)
--------producer()
--------lib.rs(12KB)
--------groups.rs(4KB)
--------admin.rs(41KB)
----Dockerfile(843B)
----coverage.sh(2KB)
----readme_template(1020B)
----examples()
--------asynchronous_processing.rs(7KB)
--------metadata.rs(4KB)
--------smol_runtime.rs(4KB)
--------roundtrip.rs(3KB)
--------at_least_once.rs(6KB)
--------simple_producer.rs(3KB)
--------simple_consumer.rs(5KB)
--------example_utils.rs(1KB)
----CONTRIBUTING.md(1KB)
----rdkafka-sys()
--------Cargo.toml(3KB)
--------librdkafka()
--------src()
--------update-bindings.sh(1KB)
--------readme_template(47B)
--------build.rs(8KB)
--------CONTRIBUTING.md(358B)
--------README.md(4KB)
--------tests()
--------changelog.md(1KB)
----test_suite.sh(1KB)
----LICENSE(1KB)
----rdkafka.suppressions(414B)
----README.md(11KB)
----generate_readme.py(1KB)
----docker-compose.yaml(676B)
----tests()
--------test_admin.rs(15KB)
--------test_low_producers.rs(10KB)
--------utils.rs(7KB)
--------test_high_consumers.rs(13KB)
--------test_transactions.rs(6KB)
--------test_high_producers.rs(4KB)
--------test_metadata.rs(6KB)
--------test_low_consumers.rs(12KB)
----.gitignore(29B)
----changelog.md(17KB)