暂时有这些 Cooncetor,其中这些并不是 Flink 自带的,需要自己定义,另外提供这些 Connector 的使用案例,大家可以参考。欢迎补充和点赞
.
├── README.md
├── flink-learning-connectors-activemq
├── flink-learning-connectors-akka
├── flink-learning-connectors-cassandra
├── flink-learning-connectors-clickhouse
├── flink-learning-connectors-es2
├── flink-learning-connectors-es5
├── flink-learning-connectors-es6
├── flink-learning-connectors-es7
├── flink-learning-connectors-flume
├── flink-learning-connectors-gcp-pubsub
├── flink-learning-connectors-hbase
├── flink-learning-connectors-hdfs
├── flink-learning-connectors-hive
├── flink-learning-connectors-influxdb
├── flink-learning-connectors-kafka
├── flink-learning-connectors-kinesis
├── flink-learning-connectors-kudu
├── flink-learning-connectors-mysql
├── flink-learning-connectors-netty
├── flink-learning-connectors-nifi
├── flink-learning-connectors-pulsar
├── flink-learning-connectors-rabbitmq
├── flink-learning-connectors-redis
└── flink-learning-connectors-rocketmq