konsumer_offsets

A library crate to parse the content of the Kafka __consumer_offsets internal topic.

Features

• Most complete parser for __consumer_offsets messages out there
• Reverse-engineering of Kafka 3.x parsing logic, making it retro-compatible by default
• Able to parse the subscription and assignment data contained in GroupMetadata messages: beyond what even the Kafka own parser can do
• Every struct and field is well documented
• Internal parsing functions are also documented and have references to the code they are based upon: if you read the code, you can go correlate to the Kafka codebase that its imitating
• Parsing is based on bytes_parser and errors on thiserror, so it's easy to read and handles result errors idiomatically
• All types exported by this crate are "Thread Safe" and "Async/Await Safe": we enforce the implementation of Sized + Send + Sync + Unpin
• Support (via feature flags) to parse Unix timestamps via the chrono or time crates
• Support (via feature flags) for serialization/deserialization via the serde crate

License

Licensed under either of

• Apache License, Version 2.0 (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
• MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.