apache-kafka - 生成的 WallclockTimestampExtractor 时间戳在处理时间戳之前

Question

我有一个拓扑，它从topicA做一些处理中读取事件，在此期间它使用 将其中一个字段设置为当前时间戳，System.currentTimeMillis并将结果发送到topicB. 此应用程序已WallclockTimestampExtractor设置为默认值。

我设置了另一个从两个主题读取的拓扑，以测量每个 eventType 的延迟，但是，我从中获得processorContext.timestamp 的时间戳在我在 payload 上设置的处理时间戳之前。据我了解 WallclockTimestampExtractor 将为事件设置时间戳，该时间戳等于将事件放入主题的时间，因此在处理时间之前应该不可能有这个时间。

我错过了什么？

标签： apache-kafkaapache-kafka-streams

Answer 1

设置message.timestamp.type=LogAppendTime主题为我解决了它