Confluent-Kafka-Python：获取每个主题分区的延迟
Confluent-Kafka-Python: Get lag per topic partition
confluent-kafka-python 想知道是否可以通过 Admin API 或任何其他 api 获取每个 topic partition 的延迟？
找到这个 link to be helpful 但想检查是否有直接可用的 api？
您不需要 AdminClient。
您可以获得主题分区的高水位线，并且可以直接从 Consumer 实例中获取消费者的 current/committed 位置，如链接示例所示...减去这些，就会出现滞后。
或者，您可以安装像 Burrow 这样的工具，并使用来自 Python
的 REST API
confluent-kafka-python 想知道是否可以通过 Admin API 或任何其他 api 获取每个 topic partition 的延迟？
找到这个 link to be helpful 但想检查是否有直接可用的 api？
您不需要 AdminClient。
您可以获得主题分区的高水位线，并且可以直接从 Consumer 实例中获取消费者的 current/committed 位置，如链接示例所示...减去这些，就会出现滞后。
或者，您可以安装像 Burrow 这样的工具，并使用来自 Python
的 REST API