command-line - 知道偏移量 kafka 是否已重置的命令

Question

最近我更改了主题的名称，然后我的消费者似乎阅读了该主题的所有消息，而忽略了偏移量。我想知道是否有人知道我可以检查我的偏移量是否已重置的命令？

谢谢马库斯

标签： command-lineapache-kafka

Answer 1

在卡夫卡版本 2+

如果您描述您的消费者组可以看到偏移量：

kafka-consumer-groups  --describe --group <consumer group name> --bootstrap-server <kafka broker IP>:9092

要将偏移更改为最新：

kafka-consumer-groups --bootstrap-server <kafka broker IP>:9092 --group <consumer group name> --topic <Topic name> --reset-offsets --to-latest --execute

根据您的 kafka 消费者，消费者组具有从头开始、从偏移量或最新读取消息的属性。