java - 如何处理 Kafka Streams 中的不同时区？

Question

因此，我正在评估 Kafka Streams 以及它可以做些什么来查看它是否适合我的用例，因为我需要每隔 15 分钟、每小时、每天聚合一次传感器的数据，并且由于它的 Windowing 功能而发现它很有用。因为我可以通过应用创建窗口，windowedBy()但KGroupedStream问题是窗口是在 UTC 中创建的，我希望我的数据按其原始时区而不是按 UTC 时区分组，因为它阻碍了聚合，所以任何人都可以帮助我解决这个问题。

标签： javaapache-kafkaapache-kafka-streams

Answer 1

您可以使用自定义“移动”时间戳TimestampExtractor- 在将结果写回输出主题之前，您可以使用 aTransformer并通过context.forward(key, value, To.all().withTimestamps()).

功能请求票：https ://issues.apache.org/jira/browse/KAFKA-7911