apache-kafka - 使用命令行在kafka中使用消息时如何设置组名？

Question

知道如何在使用命令行在 kafka 中使用消息时设置组名。

我尝试使用以下命令:

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic nil_RF2_P2 --from-beginning --config group.id=test1
'config' is not a recognized option

目标是使用以下命令找到消耗消息的偏移量:

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group test1

有人可以在这方面提供帮助吗!!

提前致谢 !!

Answer 1

最简单的解决方案是:

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic nil_RF2_P2 --from-beginning --consumer-property group.id=test1

如果您指定标志 --从头开始请记住，消费者组过去不应该消费任何记录，否则您的消费者将从指定组最早未消费的记录开始消费(而不是从实际开始，因为您可能
错误地假设)。