Проблема с соединителем источника JDBC Confluent - PullRequest
Новая
       10

Проблема с соединителем источника JDBC Confluent

0 голосов
/ 16 января 2019

При попытке использовать конфлюент для kafka-connect возникает следующая проблема. Я пытаюсь следовать демонстрации на 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`"
}

1 Ответ

0 голосов
/ 17 января 2019

Сообщение 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

...