apachekafka流/ksql如何处理无序/延迟消息？

rekjcdws 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(368)

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

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

但是我在ksql中找不到相关的部分，还不支持吗？
我能用Kafka流做准确的统计而不给最大容忍滞后（因为我不确定）？就像apache flink sideoutputlatedata一样，它专门处理延迟消息。

1条答案

ksql使用kafka流，因此目前window的保留策略是1天。目前您无法在语法中配置它，但可以将其添加到窗口语法中。我鼓励您在ksql存储库中添加一个特性请求（github问题）(https://github.com/confluentinc/ksql)为了这个。