如何使用Apache Kafka Streams查找最后一个跳转窗口

Question

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

.windowedBy(TimeWindows.of(Duration.ofSeconds(30)).advanceBy(Duration.ofSeconds(30)).grace(Duration.ZERO))

.suppress(Suppressed.untilWindowCloses(Suppressed.BufferConfig.unbounded()))

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

Answer 1

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