说明
Flink 可以通过 Sink 进行存储操作,但官方为很多 外部系统 提供 数据读写 连接器,既可以当成数据源,也能当成目的地,操作起来更加安全、简单
官方支持的连接器如下:
- Apache Kafka (source/sink)
- Apache Cassandra (sink)
- Amazon Kinesis Streams (source/sink)
- Elasticsearch (sink)
- Hadoop FileSystem (sink)
- RabbitMQ (source/sink)
- Apache NiFi (source/sink)
- Twitter Streaming API (source)
- Google PubSub (source/sink)
其中结尾的 source 表示数据源,sink 表示数据的发送地
如:常见的消息中间件 Apache Kafka,既可以作为数据源,也能成为数据的发送目的地。