指定 Kafka Connect 连接器插件版本

Question

Kafka 如何处理

CLASSPATH

中提供的同一连接器插件的多个版本？例如，假设我将

mongo-kafka-1.0.0-all.jar

和

mongo-kafka-1.1.0-all.jar

都放入各自的目录中，以便允许使用这两个版本，具体取决于需要的内容。不幸的是，文档没有给出指定

connector.class

版本的方法，我只能假设这是像 classloading 通常处理 Java 那样处理的。

Answer 1

如果您有共享相同连接器类的相同连接器插件（例如

io.confluent.connect.jdbc.JdbcSinkConnector

）并且您想要同一连接器 JAR 的不同版本，则需要运行多个 Kafka Connect 工作线程。

如果您有不同的连接器使用不同的依赖 JAR，那么这将由 Kafka Connect 的类路径隔离和

plugin.path

设置来处理。

Answer 2

您是否以某种方式解决了问题？我也有类似的情况