java - 如何在java中的kafka中获取消费者组的消费者滞后答案

【问题标题】：How to get Consumer Lag for a consumer group in kafka in javajava - 如何在java中的kafka中获取消费者组的消费者滞后
【发布时间】：2019-09-27 05:50:36
【问题描述】：

我想知道使用 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

【问题讨论】：

【解决方案1】：

延迟大约为endOffset-currentOffset。你可以使用

AdminClient.listConsumerGroupOffsets("MyGroupName").partitionsToOffsetAndMetadata()

获取组的当前偏移量。要获得结束偏移量，您需要为主题创建 KafkaConsumer 并使用

KafkaConsumer.endOffsets(partitions)

【讨论】：