java - 如何查找 Kafka 主题中未删除的第一条消息

Question

我有一个主题，里面有一些消息。保留时间结束后，部分消息被删除，包括偏移点的消息和其后的许多消息。

如何在主题中找到最旧的现有消息？我听说API中有一些方法，但我找不到。如果有人知道怎么做，请帮忙，因为我已经通过在文档中搜索它而受到折磨。提前致谢。

标签： javaapache-kafkakafka-consumer-api

Answer 1

您可以使用kafka-console-consumerwith--max-messages 1和--from-beginning来获取最旧的消息：

kafka-console-consumer --bootstrap-server localhost:9092 --topic topic_name --from-beginning --max-messages 1