Когда я пытаюсь подключиться к mysql8.0 с помощью kafka connect, всегда возникает проблема с моим драйвером.
Проблема не в подходящем драйвере для найденного
Это для нового CentOS7
plugin.path = [share / java, /root/confluent-5.2.1/share/confluent-hub-components]
В каталоге /root/confluent-5.2.1/share/confluent-hub-components,
есть водители буксира:
[root@localhost confluent-hub-components]# ls
confluentinc-kafka-connect-jdbc debezium-debezium-connector-mysql
Мой драйвер
[root@localhost confluent-hub-components]# cd confluentinc-kafka-connect-jdbc/
[root@localhost confluentinc-kafka-connect-jdbc]# ls
assets doc etc lib manifest.json
[root@localhost confluentinc-kafka-connect-jdbc]# cd lib
[root@localhost lib]# ls
audience-annotations-0.5.0.jar jline-0.9.94.jar kafka-connect-jdbc-5.2.1.jar postgresql-9.4-1206-jdbc41.jar sqlite-jdbc-3.25.2.jar zookeeper-3.4.13.jar
common-utils-5.2.1.jar jtds-1.3.1.jar netty-3.10.6.Final.jar slf4j-api-1.7.25.jar zkclient-0.10.jar
Вот мой код
bin/connect-standalone etc/schema-registry/connect-avro-standalone.properties etc/kafka-connect-jdbc/mysql-source.properties
mysql-source.properties:
#tasks to create:
name=jdbc-source-mysql-01
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
#tasks.max=1
# a table called 'users' will be written to the topic 'test-mysql-jdbc-users'.
connection.user=root
connection.password=root
connection.url=jdbc:mysql://localhost:3306/employees
mode=bulk
#incrementing.column.name=fdsid
topic.prefix=test-mysql-jdbc-
Ошибка:
Invalid value java.sql.SQLException: No suitable driver found for jdbc:mysql://localhost:3306/employees for configuration Couldn't open connection to jdbc:mysql://localhost:3306/employees