Kafka-Connect - Невозможно запустить исходный соединитель jdbc с MySql, используя Confluent Platform - PullRequest
Новая
       19

Kafka-Connect - Невозможно запустить исходный соединитель jdbc с MySql, используя Confluent Platform

1 голос
/ 02 июня 2019

Я использую Confluent platform 5.2.1 и исходный соединитель jdbc для чтения данных из таблицы MySql.Я сделал все необходимые изменения конфигурации, а также исходный соединитель JDBC и файлы драйвера MySql находятся в каталоге share/java/kafka-connect-jdbc.Я успешно запустил все процессы, т.е. zookeeper, реестр схемы, kafka connect и т. Д. Когда я пытаюсь выполнить настройку соединителя, чтобы начать чтение данных из MySql, я получаю сообщение об ошибке ниже - 

{"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/test?user=test_user&password=Welc0me! for configuration Couldn't open connection to jdbc:mysql://localhost:3306/test?user=test_user&password=Welc0me!\nInvalid value java.sql.SQLException: No suitable driver found for jdbc:mysql://localhost:3306/test?user=test_user&password=Welc0me! for configuration Couldn't open connection to jdbc:mysql://localhost:3306/test?user=test_user&password=Welc0me!\nYou can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"}

Я ушелчерез многие блоги с самого Confluent и других веб-сайтов, но также не смог найти никакого конкретного решения, везде дается предложение поместить ваш драйвер jar в каталог share/java/kafka-connect-jdbc, который я уже сделал.

ДополнительноИнформация -

  1. Я использую MySql 8.0.16 и jar драйвера также 8.0.16, чтобы избежать проблемы совместимости.
  2. Я установил classpath и плагин.переменная пути к той же папке, где установлены файлы jar.
  3. Я работаю в автономном режиме.
  4. Ниже приведены свойства MySql, которые я использую - 
{ 
        "name": "jdbc_source_mysql_foobar_01",
        "config": {
                "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
                "key.converter": "io.confluent.connect.avro.AvroConverter",
                "key.converter.schema.registry.url": "http://localhost:8081",
                "value.converter": "io.confluent.connect.avro.AvroConverter",
                "value.converter.schema.registry.url": "http://localhost:8081",
                "connection.url": "jdbc:mysql://localhost:3306/test?user=test_user&password=Welc0me!",
                "table.whitelist": "foobar",
                "mode": "timestamp",
                "timestamp.column.name": "update_ts",
                "validate.non.null": "false",
                "topic.prefix": "mysql-"
        }
}

Пожалуйста, дайте мне знать, если какой-либо другой ввод необходим с моей стороны, я застрял и заблокирован полностью.Любая помощь будет оценена.

...