Skip to content
A third-part enhanced edition of Apache official kafka-clients. The 'Best practice' of kafka consumer and producer.
Java
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
src
.gitignore
LICENSE
README.md
pom.xml

README.md

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. 基于长期生产实践保证数据不重复、不丢失。

该项目距今已经很久,部分功能可能已经过时,作者推荐使用spring-projects/spring-kafka替代,大部分kafka的坑,spring-kafka都会为你填平。

You can’t perform that action at this time.