Rust library for Kafka wire protocol, generating and parsing messages
kafka-wire provides Rust crates that generate Kafka request/response types and handle RecordBatch encoding/decoding without any networking or async runtime. It lets developers focus on socket management while the library guarantees version‑correct framing and bounded parsing. The project includes fuzz tests, compression support, and generated code tied to a specific Kafka commit, making it reliable for building Kafka clients or brokers. It stands out by offering a pure Sans‑IO implementation that integrates easily into any Rust networking stack.
View on GitHub →kafkars/kafka-wire