Flink为各种存储系统(如Kafka

Flink为各种存储系统(如Kafka,Kinesis,Elasticsearch和JDBC数据库系统)提供了丰富的连接器。它还具有连续的文件系统源,用于监视以时间分区方式写入文件的目录和接收器

如果kafka版本为0.8或者0.9
导入flink-connector-kafka-0.8_2.11-1.6.1.jar/flink-connector-kafka-0.9_2.11-1.6.1.jar
和flink-connector-kafka-base_2.11-1.6.1.jar 即可。
如果kafka版本为0.10
出去flink-connector-kafka-0.10_2.11-1.6.1.jar 和flink-connector-kafka-base_2.11-1.6.1.jar以外,还需要导入一个老版本的(比如flink-connector-kafka-0.9_2.11-1.6.1.jar)才可以

如果是水印(事件时间场景),则方法processWatermark将会被调用

原文地址:https://www.cnblogs.com/huiandong/p/10042227.html