【问题标题】:Get kafka record timestamp by partition and offset通过分区和偏移量获取kafka记录时间戳
【发布时间】:2021-05-03 09:05:42
【问题描述】:

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

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

【问题讨论】:

    标签: apache-kafka


    【解决方案1】:

    org.apache.kafka.clients.consumer.ConsumerRecord 有一个名为 timestamp() 的方法。 这是你要找的吗?

    【讨论】:

    • 是的,我可以通过编程方式获得它。但我在服务器控制台中使用了它。我想在不为此任务编写任何工具的情况下获取该记录的时间戳。
    • 您可以在 kafka-console-consumer 中使用“--property print.timestamp=true”来显示消息的时间戳。
    • 这就是我一直在寻找的。谢谢@guobiao-mo
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2018-09-11
    • 2019-11-25
    • 2011-02-28
    • 1970-01-01
    • 2017-01-06
    相关资源
    最近更新 更多