使用命令行在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

如果您指定了标志--from-beginning,请记住消费者组不应该过去使用过任何记录,否则您的消费者将从指定组中最早未消费的记录开始消费(而不是从实际开始消费) ,你可能错误地假设).

Answer 2

得到了从命令提示符更改组名的答案!!

脚步:

1. consumer.properties比如创建一个新文件consumer1.properties.
2. 改变group.id=<Give a new group name>了consumer1.properties.
3. bin/kafka-console-consumer.sh --new-consumer --bootstrap-server localhost:9092 --topic topicname --from-beginning --consumer.config config/consumer1.properties --delete-consumer-offsets