【发布时间】：2019-04-02 19:31:24
【问题描述】：
Kafka 消息元中的时间戳表示 Kafka 生产者发送消息的时间，但我的目标是提取消息到达 Kafka 集群的时间。有什么办法可以提取出来吗？
【问题讨论】：
标签： apache-kafka kafka-consumer-api
【发布时间】：2019-04-02 19:31:24
【问题描述】：
默认情况下，Kafka 将使用生产者提供的时间戳。
但是，您也可以通过在您的主题上将 message.timestamp.type 设置为 LogAppendTime 来让 Kafka 在将记录写入日志时更新时间戳。
请参阅文档中的topic configurations section。
【讨论】：