如何使用 Apache Kafka Streams 找到最后一个跳跃窗口答案

【问题标题】：How to find last hopping window using Apache Kafka Streams如何使用 Apache Kafka Streams 找到最后一个跳跃窗口
【发布时间】：2021-08-19 08:17:23
【问题描述】：

我正在尝试使用跳跃窗口在最后 30 秒内获得平均值。这是窗口和抑制代码；

.windowedBy(TimeWindows.of(Duration.ofSeconds(30)).advanceBy(Duration.ofSeconds(30)).grace(Duration.ZERO))
 
.suppress(Suppressed.untilWindowCloses(Suppressed.BufferConfig.unbounded()))

当我这样做时，我会在 30 秒内获得跳跃窗口。但我只对最后 30 秒感兴趣。我能抓住最后一个跳窗吗？然后我将使用 Java 树集在该窗口中查找前 5 个平均值。

【问题讨论】：

标签： apache-kafka apache-kafka-streams spring-cloud-stream

【解决方案1】：

如果您只想要最新的，您可以将窗口放在 KTable 中，如果它们具有相同的键，您将只有最新的窗口在表中。

【讨论】：

所有窗口键互不相同。如何将它们使用相同的键？
可以使用map操作
我做不到。因为窗口键上没有任何标识字段。我得到了每次迭代都会改变的窗口哈希码。