如何解决按分区和偏移量获取kafka记录时间戳
有许多线程描述了如何从 Kafka 获取从指定时间戳开始的记录。 所以我认为 Kafka “知道”它存储的每条记录的时间戳。 我需要获取具有指定分区和偏移量的记录的时间戳。可能吗？
信息系统将错误的数据放入 Kafka（客户订单中的产品 ID 不正确），我需要分析日志文件以找出原因。知道该记录的时间戳会容易得多。
解决方法
org.apache.kafka.clients.consumer.ConsumerRecord 有一个叫做 timestamp() 的方法。 这是您要找的吗？
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
