apache-kafka - Kafka Streams 是否可能在不同节点有不同的上下文时间？

Question

是ProcessorContext#timestamp()返回当前节点的时间还是整个拓扑？

不同节点有可能有不同的流时间吗？

例如，如果ProcessorContext#schedule()is 的实现因节点而异。

标签： apache-kafkaapache-kafka-streams

Answer 1

在我看来，它ProcessorContext#timestamp()返回的是记录时间戳，而不是流时间。

根据他们处理的记录，不同的节点可能有不同的流时间。每个节点的流时间只会在处理另一条记录后增加，因此每个节点都会根据他们处理的内容拥有自己的本地流时间视图。