apache-kafka - Apache Kafka Stream / KSQL 如何处理乱序/延迟消息？

Question

据我所知，kafka 流通过保留窗口处理延迟消息以容忍延迟，例如

TimeWindows.of(TimeUnit.MINUTES.toMillis(2))
                   .until(TimeUnit.DAYS.toMillis(1) /* keep for one day */)

1. 但是我在KSQL中找不到相关的部分，还不支持？
2. 我可以通过 kafka 流进行准确的统计而不给出最大容忍滞后（因为我不确定）吗？就像 Apache Flink sideOutputLateData专门处理延迟消息一样。

Answer 1

KSQL 使用 Kafka Streams，所以目前窗口的保留策略是 1 天。目前您无法在语法中配置它，但可以将其添加到窗口语法中。我鼓励您为此在 KSQL 存储库 ( https://github.com/confluentinc/ksql ) 中添加功能请求（GitHub 问题）。