融合 JDBC 源连接器出现问题

Question

我在尝试使用 confluent 进行 kafka 连接时遇到了以下问题。我正在尝试按照 https://www.confluent.io/blog/simplest-useful-kafka-connect-data-pipeline-world-thereabouts-part-1/给出的演示进行操作

错误：

./bin/confluent load jdbc_source_mysql_foobar_01 -d /tmp/kafka-connect-jdbc-source.json
{
This CLI is intended for development only, not for production
https://docs.confluent.io/current/cli/index.html
{
  "error_code": 400,
  "message": "Connector configuration is invalid and contains the following 2 error(s):nInvalid value java.sql.SQLException: No suitable driver found for jdbc:mysql://localhost:3306/demo?user=root&password=tiger for configuration Couldn't open connection to jdbc:mysql://localhost:3306/demo?user=root&password=tigernInvalid value java.sql.SQLException: No suitable driver found for jdbc:mysql://localhost:3306/demo?user=root&password=tiger for configuration Couldn't open connection to jdbc:mysql://localhost:3306/demo?user=root&password=tigernYou can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"
}

Answer 1

消息No suitable driver found for意味着找不到正确的JDBC驱动程序。

根据文章修复上述错误，您需要将适当的jdbc驱动程序放在share/java/kafka-connect-jdbc

要使用 JDBC

连接器，您需要为源数据库提供相关的 JDBC 驱动程序。连接器附带了 PostgreSQL 和 sqlite 的驱动程序——对于所有其他连接器，请下载相应的 JAR 并将其放在 share/java/kafka-connect-jdbc 中。您可以在此处找到MySQL，Oracle，SQL Server，DB2和Teradata的相关下载。

复制 jar 后，需要重启 Kafka Connect