说明

flink自身是支持多种数据源

通过 StreamExecutionEnvironment 构建数据源

有以下几种：

• 基于文件

• 基于集合

• 基于套接字

• 内置连接器

  • Apache Kafka（源/接收器）
  • Amazon Kinesis Streams（源/接收器）
  • RabbitMQ（源/接收器）
  • Apache NiFi（源/接收器）
  • Twitter Streaming API（源）
  • Google PubSub（源/接收器）

• 自定义

原文出处：/show_1IX1zbfOROEU.html