我可以通过KafkaConsumer
创建一个KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props)
。
我还可以通过ListConsumerGroupsResult list = AdminClient.listConsumerGroups()
获取“消费群体”列表。
有没有办法从KafkaConsumer
获取ListConsumerGroupsResult
?通过我的IDE和在线搜索,我没有找到这样的方法,但是我想知道SO社区中是否有人这样做。
最佳答案
您无法从使用者组结果中获得KafkaConsumer
。您可以实例化KafkaConsumer
以连接到Kafka并使用数据。
我假设您在任何特定时间都想要类似活动KafkaConsumer
的列表吗?在这种情况下,您必须使用Zookeeper中的zkCli.sh
实用程序或Curator之类的Java Zookeeper客户端来查看存储在Zookeeper中的元数据。
这是来自Kafka官方Wiki页面的Zookeeper中Kafka商店数据的很好参考:
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+data+structures+in+Zookeeper