当我像这样运行 kafka-console-consumer 时
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test
它默认属于哪个消费群体？如果我没有在命令行中指定消费者组或链接到消费者属性，它最终会使用随机消费者组吗？如何查看使用了哪个消费组？
Thanks!
如果未指定组，则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 https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L370
不幸的是，要找到生成的组 ID，您必须：
- 查看控制台消费者日志
- 列出所有组（例如使用
kafka-consumer-groups用于以以下开头的组的工具和过滤器console-consumer-.
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
