我怎样才能得到所有组列表与kafka0.10.x

当我使用kafka0.8.x，我可以通过路径“/ consumers/group_id”得到所有组的动物园管理员名单，因为偏移量将在0.8中提交给动物园管理员。X。我怎样才能得到所有组列表与kafka0.10.x

但是在版本0.10.x中，抵消承诺给kafka代理，如路径“/ brokers/topics/__customer_offsets”和路径“/ consumers”在zookeeper中没有任何内容。所以我无法通过zookeeper获得消费者组列表。

来源

2017-01-16 wxmimperio

要列出所有话题所有消费群体：

斌/ kafka-consumer-groups.sh --bootstrap服务器BROKER1：对于9092 --list

要查看偏移消费群：

斌/ kafka-consumer-groups.sh --bootstrap服务器BROKER1：9092 --describe --group测试消费群体

有关详细信息，请参见Managing Consumer Groups。

来源

2017-01-16 09:27:52 amethystic

是的，它可以使用shell命令来获取组列表。但通过API获取组信息的任何其他方式？当我从zookeeper获得组列表时，我可以获取节点信息来显示组创建时间，更新时间，这个组中有多少用户......有很多我可以从zookeeper获得的信息，但是当偏移提交给经纪人的信息比以前少，我想知道小组和消费者的结构，有没有文件可以提供？ – wxmimperio

好吧，没有提供关于如何以编程方式获取这些数据的详细信息的官方文档，但您可以尝试AdminClient.describeGroup或AdminClient.describeConsumerGroup，它们都接收组ID作为唯一参数。返回类型分别是GroupSummary和List [GroupSummary]。 GroupSummary封装了大部分您想要的信息。 – amethystic

我怎样才能得到所有组列表与kafka0.10.x

回答

相关问题