时间戳

首页 > 解决方案 > 如何在 Java 中使用 Kafka Admin Client 获取 Kafka 任何已提交偏移的提交时间？

apache-kafka - 如何在 Java 中使用 Kafka Admin Client 获取 Kafka 任何已提交偏移的提交时间？

问题描述

我正在尝试获取消费者组特定偏移量的提交时间。我检查了管理客户端 API。listConsumerGroupOffsets API 只返回偏移信息。如何获取该特定消费者组的该偏移量的时间戳（提交时间戳）？

标签： apache-kafkakafka-consumer-apikafka-producer-api

解决方案

使用以下命令更改内部主题的可见性：

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>

推荐阅读