Rust implementation of the Kafka wire protocol.
Unlike other Kafka protocol implementations, this project uses code generation to cover the entire Kafka API surface, including different protocol versions. See Kafka's repo for an example of protocol schema.
The code generator fetch the Kafka repo, and use the default branch to generate codes.
Run cargo run -p protocol_codegen
in the root path of this repo to generate/update the Rust codes via the latest Kafka
protocol schema.
Originally implemented by @Diggsey in a minimal Kafka client implementation Franz