如何使用python列出Kafka消费群体

Question

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

我使用zookeeperpython客户端（kazoo），但consumer group list为空，因为这个方法针对的是老消费者，而我们没有使用old consumer。在

如何使用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)

Answer 2

最近引入了KIP-222，使Java客户机能够检索所有消费者组。也许需要更多的时间让librdkafka或python客户机支持这一点。详见this issue。在