使用24小时的时间窗口聚合时是否可以设置时区

Question

我希望使用24小时的时间窗口聚合一些值，它可以正常工作，但是时间窗口从00:00到时间的23:59，是否可以设置时区以便时间窗口开始和结束当地时间（北京）？

Answer 1

目前（Kafka 2.0），没有时区支持。您可以做的是，在将时间戳移交给aggregation()之前修改（即移位）时间戳，然后将其移回。

根据您的应用程序，对于输入数据（不会对输出起作用，即向后移动），您可以使用自定义TimestampExtractor。

您也可以使用transfrom()运算符。在context.forward(...)中，您可以通过第三个参数To.all().withTimestamp(...)相应地设置时间戳（即向前/向后移动）。