A library crate to parse the content of the Kafka __consumer_offsets internal topic.
- Most complete parser for
__consumer_offsetsmessages 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
GroupMetadatamessages: 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
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.
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.