擅长:python、mysql、java
<p>您可以使用<a href="https://github.com/dpkp/kafka-python" rel="nofollow noreferrer">kafka-python</a>轻松列出消费者组。在</p>
<p>只需向集群中的任何代理发送<code>ListGroupsRequest</code>。在</p>
<p>例如:</p>
<pre><code>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)
</code></pre>