kafka-console-consumer 使用什么消费群

Question

当我像这样运行 kafka-console-consumer 时

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

它默认为哪个消费者组？如果我没有在命令行中指定消费者组或链接到消费者属性，它最终会使用随机消费者组吗？如何检查使用了哪个消费者组？

谢谢！

Answer 1

如果未指定组，则kafka-console-consumer.sh生成具有以下格式的随机消费者组：

console-consumer-${new Random().nextInt(100000)}

查看 ConsoleConsumer scala 类：https : //github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L370

不幸的是，要找到生成的组 ID，您必须：

• 查看控制台消费者日志
• 列出所有组（例如，使用kafka-consumer-groups工具和过滤器过滤以console-consumer-.