文件名称：Apache Kafka 的 Rust 客户端
文件大小：182KB
文件格式：ZIP
更新时间：2024-07-18 11:58:45
rust kafka kafka-rust rust-client
Kafka Rust 客户端项目状态这个项目开始由 John Ward 维护，目前的状态是我将项目更新为最新的依赖项，删除不推荐使用的 Rust 代码并调整测试。新家提议将 repo 搬到新家：https ://github.com/kafka-rust文档该库主要通过其API 文档中的示例进行记录。关于 Kafka 本身的文档可以在其项目主页上找到。安装这个 crate 与 Cargo 一起使用，并且在crates.io 上。尽管我们确实遵循语义版本控制（但预计版本号会快速增长），但 API 目前正在大量移动。[dependencies ]kafka =" 0.8"要构建 kafka-rust，通常的cargo build就足够了。crate 支持各种可以在编译时关闭的功能。参见 kafka-rust 的Cargo.toml和cargo 的文档。支持的Kafka版本kafka-rust已经过与 Kafka 0.8.2 及更新版本的兼容性测试。但是，并非 Kafka 0.9 及更新版本的所有功能都受支持。例子如前所述，货物生成的文档包含一些示例。此外，存储库的examples 目录中提
【文件预览】：
kafka-rust-master
----rustfmt.toml(76B)
----Cargo.toml(981B)
----test-data()
--------fetch2.mytopic.nocompression.kafka.0900(537B)
--------fetch2.txt(472B)
--------fetch1.mytopic.1p.nocompression.kafka.0821(12KB)
--------fetch1.mytopic.1p.snappy.kafka.0822(9KB)
--------fetch1.txt(11KB)
--------fetch1.snappy.chunked.4k(9KB)
--------README.md(2KB)
--------fetch1.mytopic.1p.gzip.kafka.0821(6KB)
--------fetch2.mytopic.nocompression.invalid_crc.kafka.0900(537B)
--------fetch1.mytopic.1p.snappy.kafka.0821(11KB)
----src()
--------consumer()
--------codecs.rs(11KB)
--------error.rs(13KB)
--------utils.rs(300B)
--------client()
--------protocol()
--------producer.rs(26KB)
--------lib.rs(1KB)
--------client_internals.rs(494B)
--------compression()
----.vscode()
--------launch.json(10KB)
----build.rs(257B)
----examples()
--------example-ssl.rs(6KB)
--------console-producer.rs(9KB)
--------example-produce.rs(2KB)
--------example-consume.rs(1KB)
--------offset-monitor.rs(12KB)
--------console-consumer.rs(5KB)
--------example-fetch.rs(3KB)
--------topic-metadata.rs(8KB)
----.travis.yml(2KB)
----LICENCE(1KB)
----README.md(5KB)
----tests()
--------integration()
--------.env(31B)
--------run-all-tests(3KB)
--------kafka-rust-image()
--------test_kafka.rs(4KB)
--------docker-compose.yml(441B)
--------do_until_success(273B)
----.gitignore(30B)
----kafka-rust-image.png(23KB)
----CHANGELOG.md(1KB)