指定 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

如果您有共享相同连接器 class（例如 io.confluent.connect.jdbc.JdbcSinkConnector）的相同连接器插件，并且您想要同一连接器 JAR 的不同版本，则需要 运行多个 Kafka Connect 工作人员。

如果您有使用不同依赖 JAR 的不同连接器，那么这由 Kafka Connect 的 class 路径隔离和 plugin.path 设置处理。