Kafka Consumer Group 的 Python API 描述组以拉滞后

【问题标题】：Python API for Kafka Consumer Group describe group to pull lagKafka Consumer Group 的 Python API 描述组以拉滞后
【发布时间】：2021-09-04 02:12:45
【问题描述】：

是否有任何 Python 版本的 Kafka Describe Group 可以从 kafka 获得消费者滞后？ https://docs.confluent.io/platform/current/clients/consumer.html#describe-group

【问题讨论】：

标签： python apache-kafka

【解决方案1】：

没有，但这并不意味着你不能使用类似的东西

import subprocess

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

通常，您会使用一些外部 Kafka 延迟收集器，例如 Burrow 来监控事物，而无需编写自定义 CLI 解析代码

【讨论】：