【发布时间】:2021-05-03 09:05:42
【问题描述】:
有很多线程描述了如何从指定的时间戳开始从 Kafka 获取记录。 所以我认为卡夫卡“知道”它存储的每条记录的时间戳。 我需要获取具有指定分区和偏移量的记录的时间戳。有可能吗?
信息系统将错误的数据放入Kafka(客户订单中的产品ID不正确),我需要分析日志文件以找出原因。知道该记录的时间戳会容易得多。
【问题讨论】:
标签: apache-kafka
有很多线程描述了如何从指定的时间戳开始从 Kafka 获取记录。 所以我认为卡夫卡“知道”它存储的每条记录的时间戳。 我需要获取具有指定分区和偏移量的记录的时间戳。有可能吗?
信息系统将错误的数据放入Kafka(客户订单中的产品ID不正确),我需要分析日志文件以找出原因。知道该记录的时间戳会容易得多。
【问题讨论】:
标签: apache-kafka
org.apache.kafka.clients.consumer.ConsumerRecord 有一个名为 timestamp() 的方法。 这是你要找的吗?
【讨论】: