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

08-16 03:59