因此，我正在评估 Kafka Streams 及其功能，看看它是否适合我的用例，因为我需要每 15 分钟、每小时、每天聚合传感器数据，并发现它由于其窗口功能而很有用。
因为我可以通过应用创建窗口windowedBy() on KGroupedStream但问题是窗口是在 UTC 创建的，我希望我的数据按其原始时区而不是 UTC 时区进行分组，因为它会妨碍聚合，所以任何人都可以帮助我解决这一问题。
您可以使用自定义“移动”时间戳TimestampExtractor-- 在将结果写回到输出主题之前，您可以使用Transformer并通过以下方式将时间戳“移”回去context.forward(key, value, To.all().withTimestamps()).
功能请求票：https://issues.apache.org/jira/browse/KAFKA-7911 https://issues.apache.org/jira/browse/KAFKA-7911
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
