Flink watermark+window 處理數據亂序、遲到問題

        在流計算中，咱們通常會選擇 Storm、Spark、Flink 等計算框架，而對消息隊列的選則 通常是Rabbitmq、Kafka 等，本片文章咱們主要介紹 Kafka + Flink 框架在流計算中所遇到的問題及解決方案。java         先聊下一個很古老的問題，Flink 消費Kafka中的數據，Kafka 有好幾個分區，而如何保證Flink按順序消費呢？（說詳細一點兒

>>阅读原文<<