向Kafka Connect添加连接器

Question

我正在使用Confluent Kafka Docker镜像，特别是使用这个： https://github.com/confluentinc/cp-docker-images/tree/4.0.x/examples/cp-all-in-one

我想添加MySQL连接器，通过：

• 正在下载连接器的1.5.46版本（https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-5.1.46.tar.gz）
• 用从下载的连接器（mysql-connector-java-5.1.46-bin.jar）出来的罐子安装卷
• 将CONNECT_PLUGIN_PATH添加到docker撰写文件

基本上，从撰写文件中推断感兴趣的部分，这是重要的片段：

environment:
  <cut>
  CONNECT_PLUGIN_PATH: '/etc/kafka-connect/jars/'
volumes:
  - "./mysql_connector:/etc/kafka-connect/jars/"

JAR 正确存在于 Docker 容器中。

但是，当然，如果我尝试使用连接器，我在启用的连接器列表中找不到。如果我去控制中心，我看到：

[{
    "class": "org.apache.kafka.connect.file.FileStreamSinkConnector",
    "type": "sink",
    "version": "1.0.0-cp1"
}, {
    "class": "org.apache.kafka.connect.file.FileStreamSourceConnector",
    "type": "source",
    "version": "1.0.0-cp1"
}]

Answer 1

您的插件路径需要包含实际JDBC Connect JAR文件以及MySQL JAR的路径

如果在此路径下装载MySQL JAR

/usr/share/java/kafka-connect-jdbc

然后设置< code > CONNECT _ PLUGIN _ PATH =/usr/share/Java ，就可以访问所有捆绑的连接器了。JDBC连接器将能够读/写MySQL数据。