Kafka Streams：配置Log-Append Time后Broker是否覆盖生产者/流的时间戳？

• 核心结论：当Kafka Broker将log.message.timestamp.type配置为LogAppendTime时，会完全无视生产者或Kafka Streams设置的消息时间戳，直接用消息写入Broker日志的时间覆盖原时间戳。
• Kafka Streams场景补充：不管你在Streams中通过context.forward()转发原有时间戳，还是通过punctuate()生成新的时间戳，只要Broker启用了LogAppendTime策略，最终存储在Broker日志里的时间戳都会被替换为Broker写入时刻的时间，Streams层面设置的时间戳不会生效。
• 与CreateTime的差异：你提到的CreateTime存在的不可靠性（转发/覆盖时间戳的不同行为）是发生在Kafka Streams层面的逻辑，但如果Broker强制使用LogAppendTime，这些Streams层面的时间戳处理都会被Broker的统一替换逻辑覆盖，不会影响最终存储的时间戳。

内容的提问来源于stack exchange，提问作者hermanjakobsen