Confluent-Kafka-Python:每个主题分区的延迟

Question

合流-卡夫卡-蟒蛇想知道是否可以通过Admin API或其他api获取每个topic partition的滞后值？找到了这个链接是有用的，但是想要检查是否有直接的api可用呢？

Answer 1

你不需要AdminClient。

您可以获得主题分区的高水印信息，也可以直接从使用者实例获取使用者当前/提交的位置，如链接的示例所示.减去这些，你就有了滞后。

或者，您可以安装像Burrow这样的工具，并使用Python中的REST。