使用 24 小时的时间 window 聚合时是否可以设置时区
Is it possible to set timezone when aggregate using time window of 24 hours
我想使用 24 小时的时间 window 聚合一些值，它工作正常，但是从 00:00 到 23:59 的时间 window 是 utc 时间，是是否可以设置时区，使时间 window 开始和结束于我当地时间（北京）？
目前（Kafka 2.0）不支持时区。您可以做的是，在将时间戳移入 aggregation() 之前修改（即移动）时间戳，然后再将它们移回。
根据您的应用程序，对于输入数据（不适用于输出，即移回），您可以使用自定义 TimestampExtractor.
您还可以使用 transfrom() 运算符。在 context.forward(...) 中，您可以通过第三个参数 To.all().withTimestamp(...).
相应地设置时间戳（即移位 forward/backward）
我想使用 24 小时的时间 window 聚合一些值，它工作正常，但是从 00:00 到 23:59 的时间 window 是 utc 时间，是是否可以设置时区，使时间 window 开始和结束于我当地时间（北京）？
目前（Kafka 2.0）不支持时区。您可以做的是，在将时间戳移入 aggregation() 之前修改（即移动）时间戳，然后再将它们移回。
根据您的应用程序，对于输入数据（不适用于输出，即移回），您可以使用自定义 TimestampExtractor.
您还可以使用 transfrom() 运算符。在 context.forward(...) 中，您可以通过第三个参数 To.all().withTimestamp(...).