网上的重复的太多了,自己记一下

查看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
Logo

大数据从业者之家,一起探索大数据的无限可能!

更多推荐