Skip to main content

Connectors

Predefined Sources and Sinks​

A few basic data sources and sinks are built into Flink and are always available. The predefined data sources include reading from files, directories, and sockets, and ingesting data from collections and iterators. The predefined data sinks support writing to files, to stdout and stderr, and to sockets.

Connectors provide code for interfacing with various third-party systems. Currently these systems are supported as part of the Apache Flink project:

  • Apache Kafka (source/sink)
  • Apache Cassandra (source/sink)
  • Amazon DynamoDB (sink)
  • Amazon Kinesis Data Streams (source/sink)
  • Amazon Kinesis Data Firehose (sink)
  • DataGen (source)
  • Elasticsearch (sink)
  • Opensearch (sink)
  • FileSystem (source/sink)
  • RabbitMQ (source/sink)
  • Google PubSub (source/sink)
  • Hybrid Source (source)
  • Apache Pulsar (source)
  • JDBC (sink)
  • MongoDB (source/sink)
  • Prometheus (sink)