Kafka消费者组的Python API描述组拉延迟

Question

是否有任何Python版本的Kafka描述组来从Kafka获得消费者延迟?https://docs.confluent.io/platform/current/clients/consumer.html描述组

Answer 1

没有，但这并不意味着你不能使用像

这样的东西

import subprocess
subprocess.Popen(["kafka-consumer-groups", "--describe", ...])

一般来说，你会使用一些外部Kafka延迟收集器，比如Burrow来监控事情，而不需要编写自定义的CLI解析代码