apache-kafka - kafka 流如何计算水印？

Question

Kafka Streams 是否在内部计算水印？是否可以在完成时(即当水印通过窗口结束时)观察窗口的结果(仅)？

Answer 1

Kafka Streams 在内部不使用水印，但是 2.1.0 中的一个新功能可以让您观察窗口关闭时的结果。它叫Suppressed ，你可以在文档中阅读它:Window Final Results :

KGroupedStream<UserId, Event> grouped = ...;
grouped
    .windowedBy(TimeWindows.of(Duration.ofHours(1)).grace(ofMinutes(10)))
    .count()
    .suppress(Suppressed.untilWindowCloses(unbounded()))