Невозможно подключиться к SQLServer Kafka Connect - PullRequest
Новая
       5

Невозможно подключиться к SQLServer Kafka Connect

0 голосов
/ 25 мая 2018

У меня есть образ докера, расположенный здесь https://github.com/Landoop/fast-data-dev, в котором есть все хорошее, что я использую для разработки.Я пытался добавить JDBC-коннектор, чтобы протолкнуть его в тему Kafka, но получаю эту ошибку.У меня есть потребитель на Java, который работает нормально, но я хотел бы использовать KafkaConnect

Invalid value java.sql.SQLException: No suitable driver found for jdbc:sqlserver://servername for configuration Couldn't open connection to jdbc:sqlserver://servername

name=JdbcSourceConnector
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
connection.user=user
connection.password=password
tasks.max=1
connection.url=jdbc:sqlserver://servername
topic.prefix=test
table.whitelist=dbo.IB_WEBLOG_DUMMY_small
query=SELECT * FROM IB_WEBLOG_DUMMY_small
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter=org.apache.kafka.connect.json.JsonConverter
poll.interval.ms=5000
table.poll.interval.ms=120000
mode=bulk

Что мне нужно искать, чтобы решить эту проблему?

1 Ответ

0 голосов
/ 25 мая 2018

Файл JAR вашего драйвера JDBC отсутствует в пути к классу Kafka Connect.Положите его туда, и вы будете готов к работе :

Один из вариантов - установить банку с драйвером JDBC рядом с разъемом.Упакованный соединитель устанавливается в каталог share/java/kafka-connect-jdbc относительно каталога установки.Если вы установили из пакетов Debian или RPM, соединитель будет установлен в /usr/share/java/kafka-connect-jdbc.Если вы установили из файлов zip или tar, соединитель будет установлен по указанному выше пути в каталоге, в который вы распаковали архив Confluent Platform.

В качестве альтернативы вы можете установить переменную CLASSPATH перед запуском connect-standalone илиподключить распределенный.Например:

$ CLASSPATH=/usr/local/firebird/* ./bin/connect-distributed ./config/connect-distributed.properties

В качестве альтернативы, поместите все файлы JAR JDBC SQL Server в каталог libs в корневой папке Apache Kafka.Но это загрязнило бы путь к классам, и его лучше избегать на производстве.

...