强制 flink 使用不同的 kafka 客户端 jar

Question

我正在使用Flink Connector Kafka 1.8.0。(取决于卡夫卡客户端 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 是否支持它，即便如此，它是如何通过 格拉德尔？

你能帮忙吗？

Answer 1

是的，您可以通过简单地将依赖项与所需的版本显式包含来配置它

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 dependencies