我正在使用Flink Connector Kafka 1.8.0。(取决于kafka-clients 2.0.1)
https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kafka_2.12/1.8.0
使用gradle:
// https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kafka
compile group: 'org.apache.flink', name: 'flink-connector-kafka_2.12', version: '1.8.0'我想知道是否可以强制它使用kafka-clients 2.4.0
我想知道flink是否支持它,即便如此,如何通过gradle配置它?
你能帮忙吗?
发布于 2020-01-06 17:05:48
可以,您只需将依赖项显式包含在所需的版本中即可对其进行配置
compile group: 'org.apache.flink', name: 'flink-connector-kafka_2.12', version: '1.8.0'
compile group: 'org.apache.kafka', name: 'kafka_2.13', version: '2.4.0'您可以测试选择了哪个版本
gradle dependencieshttps://stackoverflow.com/questions/59485804
复制相似问题