konsumer_offsets

一个库包，用于解析 Kafka __consumer_offsets 内部主题的内容。

功能

• 目前最完整的 __consumer_offsets 消息解析器
• 逆向工程 Kafka 3.x 解析逻辑，默认实现向后兼容
• 能够解析 GroupMetadata 消息中包含的 订阅 和 分配 数据：甚至超过了 Kafka 自身解析器的功能
• 每个结构体和字段都有良好的文档说明
• 内部解析函数也有文档说明，并引用了它们所基于的代码：如果你阅读了代码，你可以关联到它所模仿的 Kafka 代码库
• 解析基于 bytes_parser 和 thiserror，因此易于阅读，并以惯用方式处理结果错误
• 本crate导出的所有类型都是“线程安全”和“异步/await安全”：我们强制实施 Sized + Send + Sync + Unpin
• 支持（通过功能标志）通过chrono或time crate解析Unix时间戳
• 支持（通过功能标志）通过serde crate进行序列化/反序列化

许可证

在以下任一许可证下获得许可：

• Apache License，版本2.0（LICENSE-APACHE或https://apache.ac.cn/licenses/LICENSE-2.0）
• MIT许可证（LICENSE-MIT或http://opensource.org/licenses/MIT）

任选其一。

贡献

除非你明确声明，否则，根据Apache-2.0许可证定义，任何有意提交以包含在你所做的工作中的贡献，将按上述方式双许可，不附加任何额外条款或条件。