Confluent JDBC Source连接器的问题 [英] Issue with Confluent JDBC Source connector

问题描述

在尝试将融合器用于kafka-connect时出现以下问题.我正在尝试按照 https://www.confluent.io/blog/simplest-useful-kafka-connect-data-pipeline-world-thereabouts-part-1/

I'm getting the below issue while trying to use the confluent for kafka-connect. I'm trying to follow the demo given at 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=tiger\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=tiger\nYou can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"
}

推荐答案

消息No suitable driver found for表示找不到正确的jdbc驱动程序.

Message No suitable driver found for means, that proper jdbc driver cannot be found.

根据解决上述错误的文章，您需要在share/java/kafka-connect-jdbc

According to article to fix above error you need to place appropriate jdbc driver in share/java/kafka-connect-jdbc

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

To use the JDBC connector, you’ll need to make available the relevant JDBC driver for your source database. The connector ships with drivers for PostgreSQL and sqlite—for all others download the appropriate JAR and place it in share/java/kafka-connect-jdbc. You can find the relevant downloads here for MySQL, Oracle, SQL Server, DB2, and Teradata.

复制jar之后，您需要重新启动Kafka Connect

After copying jars, you need to restart Kafka Connect

这篇关于Confluent JDBC Source连接器的问题的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！