問題

Kafka Streamsは内部的に透かしを計算しますか?ウィンドウの結果(ウォーターマークがウィンドウの終わりを通過するときのみ)を観察することは可能ですか?

  ベストアンサー

Kafka Streamsは内部的には透かしを使用しませんが、2.1.0の新機能では閉じたときにウィンドウの結果を確認できます。これはSuppressedと呼ばれ、ドキュメントで読むことができます:ウィンドウ最終結果:

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

  同じタグがついた質問を見る

apache-kafkaapache-kafka-streams