我想知道使用 java 的消费者组的消费者滞后。我尝试过使用
kafka-consumer-groups --describe --bootstrap-server localhost:9092 --group MyGroupName
并且滞后是可见的。
我如何在 Java 中执行此操作？
我尝试过使用org.apache.kafka.clients.admin.AdminClient，但无法获得每个消费者组的延迟。
我在用
confluent 5.0.1 which has kafka 2.0.1
org.apache.kafka - kafka-clients - 2.0.1