Flink watermark+window 处理数据乱序、迟到问题

        在流计算中，咱们通常会选择 Storm、Spark、Flink 等计算框架，而对消息队列的选则 通常是Rabbitmq、Kafka 等，本片文章咱们主要介绍 Kafka + Flink 框架在流计算中所遇到的问题及解决方案。java         先聊下一个很古老的问题，Flink 消费Kafka中的数据，Kafka 有好几个分区，而如何保证Flink按顺序消费呢？（说详细一点儿

>>阅读原文<<