kafka-rust:Apache Kafka的Rust客户端

时间:2021-02-05 18:29:49
【文件属性】:
文件名称:kafka-rust:Apache Kafka的Rust客户端
文件大小:159KB
文件格式:ZIP
更新时间:2021-02-05 18:29:49
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)

网友评论