Flink实战(三) - 编程范式及核心概念
1 基本的 API 概念
Flink程序是实现分布式集合转换的常规程序（例如，过滤，映射，更新状态，加入，分组，定义窗口，聚合）。最初从源创建集合（例如，通过从文件，kafka主题或从本地的内存集合中读取）。
该如何选择消息队列？
在高并发业务场景下，消息队列在流量削峰、解耦上有不可替代的作用。当前使用较多的消息队列有 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、Pulsar 等。
消息队列这么多，到底该选择哪款消息队列呢？
选择消息队列的基本标准
虽然这些消息队列在功能和特性方面各有优劣，但我们在选择的时候要有一个基本标准。
