apache-kafka - 如何在kafka中找到消费者组协调员？

Question

是否有任何命令可以为我提供在 kafka 中充当我的消费者组的协调器的代理的 ID？

同样，我需要 Controller 代理的 id。

我们可以从日志文件中找到它，但我希望它在不查看日志的情况下知道

Answer 1

您可以通过 kafka-consumer-groups 找到消费者组协调员命令。例如。:

kafka-consumer-groups --bootstrap-server localhost:9092 --group sample --describe --state

GROUP                     COORDINATOR (ID)          ASSIGNMENT-STRATEGY  STATE           #MEMBERS
sample                 localhost:9092 (0)        range                Stable          1

如需更多信息，请参阅 Managing Consumer Groups

Similarly, I need id of controller broker.

请查收 How to know the broker that is the active controller?