Как получить Consumer Lag для группы потребителей в Кафке в Яве

Question

Я хочу знать отставание потребителей для группы потребителей, использующих 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

Answer 1

лаг составляет приблизительно endOffset-currentOffset. Вы можете использовать

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

чтобы получить текущее смещение для группы. Чтобы получить конечные смещения, вам нужно создать KafkaConsumer для темы и использовать

KafkaConsumer.endOffsets(partitions)