我可以通过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