文件名称：kafka-rust：Apache Kafka的Rust客户端
文件大小：159KB
文件格式：ZIP
更新时间：2024-02-26 12:16:29
rust kafka kafka-rust rust-client RustRust
kafka-rust：Apache Kafka的Rust客户端
【文件预览】：
kafka-rust-master
----.gitignore(30B)
----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(893B)
----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)
--------docker-compose.yml(441B)
--------kafka-rust-image()
--------test_kafka.rs(4KB)
----rustfmt.toml(76B)