kafka手动修改offset
今天在使用kafka时，本来需要将数据发送到topicA，却将数据发送到了topicB，导致topicB的消费者组consumerB程序无法消费topicB的内容，直接退出，因此需要手动修改partition的offset使lag等于0
分区个数10个：
看了下网上关于这方面的资料不多，只找到了一个hortonworks上面的相对靠谱[1]，查看offset:
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list blackbox01.jry.com:6667 --topic baidu_crawl_feed_plain --time -1
但是offset相关信息应该是存储在了broker中，没找到topicB所在的consumer的offset.
最后使用的办法是修改了程序，依旧以consumerB的消费者组进行消费。
ref:
[1]:https://community.hortonworks.com/articles/81357/manually-resetting-offset-for-a-kafka-topic.html
作者：joker1993
来源链接：https://blog.csdn.net/u011423145/article/details/80838769
版权声明：
1、JavaClub（https://www.javaclub.cn）以学习交流为目的，由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容，包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网，本站不享有版权，版权归原作者所有。
2、本站提供的内容仅用于个人学习、研究或欣赏，以及其他非商业性或非盈利性用途，但同时应遵守著作权法及其他相关法律的规定，不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容，请及时通知本站（javaclubcn@163.com），我们将第一时间核实后及时予以删除。
