文件名称:基于librdkafka的Rust的完全异步的,启用了期货的Apache Kafka客户端库。-Rust开发
文件大小:161KB
文件格式:ZIP
更新时间:2024-06-16 12:09:57
Rust Distributed systems
rust-rdkafka基于librdkafka的Rust的完全异步的,启用了期货的Apache Kafka客户端库。 库rust-rdkafka提供了一个安全的rust-rdkafka。这是一个基于librdkafka的Rust完全异步,启用期货的Apache Kafka客户端库。 库rust-rdkafka为librdkafka提供了一个安全的Rust接口。 master分支当前基于librdkafka 1.4.2。 文档最新版本Changelog功能当前提供的主要功能包括:支持自0.8.x起的所有Kafka版本。 有关代理兼容性选项的更多信息,请查看librdkafka文档。 从s消费
【文件预览】:
rust-rdkafka-master
----.gitignore(22B)
----Dockerfile(843B)
----src()
--------groups.rs(4KB)
--------topic_partition_list.rs(17KB)
--------producer()
--------error.rs(12KB)
--------statistics.rs(23KB)
--------metadata.rs(4KB)
--------util.rs(10KB)
--------client.rs(15KB)
--------admin.rs(41KB)
--------config.rs(10KB)
--------consumer()
--------message.rs(21KB)
--------lib.rs(12KB)
----test_suite.sh(2KB)
----changelog.md(18KB)
----Cargo.lock(38KB)
----CONTRIBUTING.md(1KB)
----rdkafka-sys()
--------src()
--------changelog.md(2KB)
--------CONTRIBUTING.md(358B)
--------Cargo.toml(3KB)
--------README.md(4KB)
--------tests()
--------readme_template(47B)
--------librdkafka()
--------update-bindings.sh(1KB)
--------build.rs(8KB)
----LICENSE(1KB)
----Cargo.toml(2KB)
----coverage.sh(2KB)
----.gitmodules(106B)
----.github()
--------workflows()
----docker-compose.yaml(676B)
----examples()
--------example_utils.rs(1KB)
--------asynchronous_processing.rs(7KB)
--------simple_producer.rs(3KB)
--------runtime_smol.rs(4KB)
--------at_least_once.rs(6KB)
--------runtime_async_std.rs(3KB)
--------metadata.rs(4KB)
--------roundtrip.rs(3KB)
--------simple_consumer.rs(5KB)
----README.md(12KB)
----tests()
--------utils.rs(7KB)
--------test_transactions.rs(6KB)
--------test_metadata.rs(6KB)
--------test_high_consumers.rs(13KB)
--------test_low_producers.rs(10KB)
--------test_high_producers.rs(4KB)
--------test_low_consumers.rs(12KB)
--------test_admin.rs(15KB)
----rdkafka.suppressions(414B)
----generate_readme.py(1KB)
----.gitattributes(238B)
----readme_template(1020B)