问Apache Kafka Stream / KSQL如何处理乱序/延迟消息？
EN

Stack Overflow用户

提问于 2018-03-09 14:07:55

回答 1查看 386关注 0票数 0

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

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

但是我在KSQL中找不到相关的部件，还不支持？
我可以通过kafka stream 做准确的统计吗，而不是给出最大容忍延迟(因为我不确定)？就像Apache Flink sideOutputLateData一样，专门处理延迟消息。

发布于 2018-03-10 01:30:21

KSQL使用Kafka Streams，因此目前window的保留策略是1天。目前您不能在语法中对其进行配置，但可以将其添加到窗口语法中。我鼓励您在KSQL存储库(https://github.com/confluentinc/ksql)中为此添加一个特性请求(GitHub问题)。

票数 2

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/49187575

复制

相似问题

问Apache Kafka Stream / KSQL如何处理乱序/延迟消息？EN