如何将 kafka-connect-jdbc-5.5.0.jar 添加到 Debezium/connect

Posted 2023-03-23

【中文标题】如何将 kafka-connect-jdbc-5.5.0.jar 添加到 Debezium/connect

【英文标题】：How to add kafka-connect-jdbc-5.5.0.jar to Debezium/connect

【发布时间】：2020-10-08 20:55:08

【问题描述】：

我已将 kafka-connect-jdbc-5.5.0.jar 文件从 confluent 下载到我的本地机器中。我想知道一种将这个 jar 添加到 plugin.path=/kafka/connect 的方法。我正在尝试将数据下沉到 mysql 服务器，所以我使用“connector.class”：“io.confluent.connect.jdbc.JdbcSinkConnector”，但我面临“error_code”：500，“message”：“找不到任何实现 Connector 并且名称与 io.confluent.connect.jdbc.JdbcSinkConnector 匹配的类，我在 windows 机器中使用 docker 工具箱

【问题讨论】：

为什么不直接使用已经有那个 JAR 的 cp-kafka-connect docker 镜像呢？或者为什么不使用confluent-hub 来安装您需要的东西？

【参考方案1】：

请检查此示例Dockerfile。它演示了如何为 JDBC 和 Elasticsearch 部署接收器连接器。 一般来说，最重要的是要记住，如果plagin.path 设置为/kafka/connect，那么连接器将被部署在名为/kafka/connect/<arbitrary_name_dirname> 的目录中。