Как получить время фиксации любого зафиксированного смещения Kafka, используя Kafka Admin Client в Java?

Question

Я пытаюсь получить время фиксации для определенного смещения группы потребителей.Я проверил API клиента администратора.API listConsumerGroupOffsets возвращает только информацию о смещении.Как я могу получить метку времени (фиксацию времени) этого смещения для этой конкретной группы потребителей?

Answer 1

Изменить видимость внутренних тем с помощью следующей команды:

echo "exclude.internal.topics=false" > /tmp/consumer.config

Используйте следующую команду, чтобы увидеть время фиксации вместе со смещением

kafka-console-consumer --consumer.config /tmp/consumer.config \
  --formatter "kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter" \
  --bootstrap-server localhost:9092 \
  --topic __consumer_offsets | grep <group_id>