kafka 2.2.1对应的安装 flink版本connector
时间: 2024-05-19 22:12:40 浏览: 221
flink-connector-kafka_2.11-1.12.7.jar中文-英文对照文档.zip
针对kafka 2.2.1,可以使用以下版本的flink-kafka-connector:
- Flink 1.9.x: flink-connector-kafka-0.11_2.11-1.9.3.jar
- Flink 1.10.x: flink-connector-kafka-0.11_2.11-1.10.2.jar
注意,以上版本都是基于kafka 0.11.x版本的connector,支持kafka 2.1.x、2.2.x、2.3.x等版本。如果需要使用kafka 2.0.x及以下版本的connector,可以使用以下版本的flink-kafka-connector:
- Flink 1.9.x: flink-connector-kafka-0.10_2.11-1.9.3.jar
- Flink 1.10.x: flink-connector-kafka-0.10_2.11-1.10.2.jar
注意,以上版本都是基于kafka 0.10.x版本的connector,支持kafka 0.9.x、0.10.x、1.0.x等版本。
阅读全文