flink1.12.x Connector连接器

说明

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,既可以作为数据源,也能成为数据的发送目的地。


原文出处:/show_1IX45D9TX5l9.html