kafka-xclient

kafka-xclient is a third-part enhanced edition of Apache official kafka-clients.

The 'Best practice' of kafka consumer and producer.

1. 提供 Consumer、Producer 易用的 API 模板;
2. 支持集中控制 consumer group 的 topic;
3. 支持多个 consumer groups，包括配置、启动、停止、查看线程状态；
4. 支持安全关闭 consumer；
5. 支持立即消费自动创建的 topic 的数据。
6. 支持 offset 的自动提交；
7. 支持 offset 的记录和检查，项目启动时 topic 可以自动 seek 到 上一次的 offset。
8. 全面的关键日志、统计输出，让你对消费情况了如指掌。
9. 支持消费超时之前自动 pause 避免 re-blance;
10. 基于长期生产实践保证数据不重复、不丢失。
    （we use it for stream computing like Apache Storm at 2016)

该项目距今已经很久（since 2016， kafka 0.8，from bigdata push platform of IoT），部分功能可能已经过时，作者推荐使用spring-projects/spring-kafka替代，很多hack功能如出一辙，大部分kafka的坑，这个工具都会为你填平！