kafka manager如何获得消费者示例所有者？ Zookeeper 或者 jmx mbean ?在新Kafka版本中，仅使用 ConsumerGroupCommand.main 为了得到主人的信息？kafka:0.10.1.0
Zookeeper
jmx mbean
ConsumerGroupCommand.main
gab6jxml1#
由于kafka0.9，信息存储在broker中。对于每个组，选择一个代理作为组协调员。重新平衡后，分配的消费者可能会发生变化。搜索 ConsumerPartitionOwnershipInfo 在设计文件中。
ConsumerPartitionOwnershipInfo
1条答案
按热度按时间gab6jxml1#
由于kafka0.9，信息存储在broker中。对于每个组，选择一个代理作为组协调员。重新平衡后，分配的消费者可能会发生变化。
搜索
ConsumerPartitionOwnershipInfo在设计文件中。