kafka管理器如何获得消费者实例的所有者?Zookeeper
还是jmx mbean
?
在新的kafka版本中,只使用ConsumerGroupCommand.main
来获取所有者信息?
卡夫卡:0.10.1.0
自Kafka 0.9以来,信息存储在代理中。对于每个组,选择一个代理作为组协调器。分配的消费者在重新平衡后可能会改变。
在设计文档中搜索ConsumerPartitionOwnershipInfo