python - 如何使用python列出Kafka消费者组

Question

我想用 python 获取 Kafka 消费者组列表，但我做不到。

我使用 zookeeper python 客户端(kazoo)，但消费者组列表为空，因为这种方法适用于旧消费者，而我们没有使用旧消费者。

如何使用python代码获取消费者组列表？

./kafka-consumer-groups.sh  -bootstrap-server localhost:9092 -list

Answer 1

您可以使用 kafka-python 轻松列出消费者组.

只需将 ListGroupsRequest 发送到集群中的任何代理即可。

例如:

from kafka import BrokerConnection
from kafka.protocol.admin import *
import socket

bc = BrokerConnection('localhost', 9092, socket.AF_INET)
bc.connect_blocking()

list_groups_request = ListGroupsRequest_v1()

future = bc.send(list_groups_request)
while not future.is_done:
    for resp, f in bc.recv():
        f.success(resp)

for group in future.value.groups:
    print(group)