kafka管理器如何获得消费者实例所有者



kafka管理器如何获得消费者实例的所有者?Zookeeper还是jmx mbean ?

在新的kafka版本中,只使用ConsumerGroupCommand.main来获取所有者信息?

卡夫卡:0.10.1.0

自Kafka 0.9以来,信息存储在代理中。对于每个组,选择一个代理作为组协调器。分配的消费者在重新平衡后可能会改变。

在设计文档中搜索ConsumerPartitionOwnershipInfo

最新更新