按分区和偏移量获取kafka记录时间戳

问题描述

有许多线程描述了如何从 Kafka 获取从指定时间戳开始的记录。 所以我认为 Kafka “知道”它存储的每条记录的时间戳。 我需要获取具有指定分区和偏移量的记录的时间戳。可能吗?

信息系统将错误的数据放入 Kafka(客户订单中的产品 ID 不正确),我需要分析日志文件以找出原因。知道该记录的时间戳会容易得多。

解决方法

org.apache.kafka.clients.consumer.ConsumerRecord 有一个叫做 timestamp() 的方法。 这是您要找的吗?