我是新的Kafka流，我有一些不清楚的点，这就是为什么我需要帮助，以了解事情是如何运作的：1.当我在kafkastreams中定义customTimeExtractor时，kafka会根据我定义的时间戳重新排序中间主题中的记录吗？2.例如，对于TumblingWindow，它如何使用我定义的新时间戳？当它检测到记录的第一个时间戳时，窗口将启动？谢谢！
92dk7w1h1#
当我在kafkastreams中定义customTimeExtractor时，kafka会根据我定义的时间戳重新排序中间主题中的记录吗？不会。记录仍然按照偏移量顺序处理，与记录嵌入的时间戳或您的自定义提取器可能返回的任何其他时间戳无关。例如，对于TumblingWindow，它如何使用我定义的新时间戳？当它检测到记录的第一个时间戳时，窗口将启动？基本上是的。对于每一个处理过的输入记录，我们检查是否已经有一个打开的窗口。如果有，记录被添加到这个窗口。如果没有，则创建一个新窗口。
1条答案
按热度按时间92dk7w1h1#
当我在kafkastreams中定义customTimeExtractor时，kafka会根据我定义的时间戳重新排序中间主题中的记录吗？
不会。记录仍然按照偏移量顺序处理，与记录嵌入的时间戳或您的自定义提取器可能返回的任何其他时间戳无关。
例如，对于TumblingWindow，它如何使用我定义的新时间戳？当它检测到记录的第一个时间戳时，窗口将启动？
基本上是的。对于每一个处理过的输入记录，我们检查是否已经有一个打开的窗口。如果有，记录被添加到这个窗口。如果没有，则创建一个新窗口。