文件名称:kafka-rust:Apache Kafka的Rust客户端
文件大小:181KB
文件格式:ZIP
更新时间:2024-05-21 06:14:16
rust kafka kafka-rust rust-client Rust
Kafka Rust客户端 项目状态 该项目开始由John Ward进行维护,当前状态是我正在使该项目与最新的依赖关系保持最新,删除不推荐使用的Rust代码并调整测试。 新家 欢迎来到kafka-rust的新家: : 文献资料 该库主要通过其示例进行。 有关Kafka本身的文档可以在。 安装 此板条箱可与Cargo一起使用,位于。 尽管我们确实遵循语义版本控制(但希望版本号Swift增长),但API的使用目前仍处于紧张状态。 [ dependencies ] kafka = " 0.8 " 要制造kafka-rust,通常的cargo build就足够了。 板条箱支持各种功能,可在编译时将其关闭。 请参阅kafka-rust的Cargo.toml和。 支持的Kafka版本 已测试kafka-rust与Kafka 0.8.2及更高版本的兼容性。 但是,尚不支持Kafka 0.9及更
【文件预览】:
kafka-rust-master
----.gitignore(30B)
----kafka-rust-image.png(23KB)
----src()
--------client()
--------utils.rs(300B)
--------client_internals.rs(494B)
--------compression()
--------error.rs(13KB)
--------producer.rs(26KB)
--------codecs.rs(11KB)
--------protocol()
--------consumer()
--------lib.rs(1KB)
----.travis.yml(2KB)
----test-data()
--------fetch1.snappy.chunked.4k(9KB)
--------fetch1.mytopic.1p.gzip.kafka.0821(6KB)
--------fetch1.mytopic.1p.snappy.kafka.0821(11KB)
--------fetch1.mytopic.1p.nocompression.kafka.0821(12KB)
--------README.md(2KB)
--------fetch1.mytopic.1p.snappy.kafka.0822(9KB)
--------fetch2.txt(472B)
--------fetch1.txt(11KB)
--------fetch2.mytopic.nocompression.kafka.0900(537B)
--------fetch2.mytopic.nocompression.invalid_crc.kafka.0900(537B)
----LICENCE(1KB)
----CHANGELOG.md(1KB)
----Cargo.toml(914B)
----examples()
--------console-producer.rs(9KB)
--------example-fetch.rs(3KB)
--------topic-metadata.rs(8KB)
--------console-consumer.rs(5KB)
--------example-ssl.rs(6KB)
--------example-consume.rs(1KB)
--------offset-monitor.rs(12KB)
--------example-produce.rs(2KB)
----README.md(5KB)
----tests()
--------run-all-tests(3KB)
--------integration()
--------do_until_success(273B)
--------.env(31B)
--------docker-compose.yml(441B)
--------kafka-rust-image()
--------test_kafka.rs(4KB)
----rustfmt.toml(76B)
----.vscode()
--------launch.json(10KB)