网上的重复的太多了，自己记一下
查看topic链接信息，消费者信息
./bin/kafka-consumer-groups.sh --bootstrap-server kafka地址 --describe --group 消费者组名 | grep topic名
输出：
- CURRENT-OFFSET ： 消费到了那个offset
- LOG-END-OFFSET ： 总 offset
- LAG ： 消费了的offset和总offset 相差多少
- CONSUMER-ID ： 消费者地址
查看topic的 message，不消费
取offset 4610 分区0 的消息且只取一条。这里指定了 offset partition
./bin/kafka-console-consumer.sh --bootstrap-server kafka地址 --topic topic名 --offset 4610 --partition 0 --max-messages 1
消费掉 topic里的一条 ，需指定group
其实和上边是一个命令就是不再指定 offset 改为指定 group，但是不能指定 partition 和 offset 。参考：https://github.com/a0x8o/kafka/blob/master/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L398
./bin/kafka-console-consumer.sh --bootstrap-server kafka地址 --topic topic名 --group 消费者组 --max-messages 1
重置某个 group的 某个 topic 的 offset
参考 https://stackoverflow.com/questions/29791268/how-to-change-start-offset-for-topic
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --reset-offsets --group local-idea --topic a554-2:0 --to-offset 10 --execute
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之家整理，本文链接：https://www.bmabk.com/index.php/post/76446.html
