Kafka0.9之后,如何获取到consuemr,topic,以及partition的offset信息
kafka0.9版本之后,consumer的消费信息不再存放在zookeeper端了,我想写java代码调到offset信息,zkClient已经不能用了,请问还有其他方式吗?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
看看kafka.tools下面的一些类,比如ConsumerOffsetChecker和kafka.admin.ConsumerGroupCommand等,或者直接用kafka-run-class.sh来运行