Kafka Connect: подходящий драйвер не найден - PullRequest
Новая
       10

Kafka Connect: подходящий драйвер не найден

0 голосов
/ 25 июня 2018

Я пробую Кафку с Postgres Sink, используя JDBC-коннектор приемника.

Исключение: 

INFO Unable to connect to database on attempt 1/3. Will retry in 10000 ms. (io.confluent.connect.jdbc.util.CachedConnectionProvider:91)
java.sql.SQLException: No suitable driver found for jdbc:postgresql://localhost:5432/casb
at java.sql.DriverManager.getConnection(DriverManager.java:689)
    at java.sql.DriverManager.getConnection(DriverManager.java:247)
    at io.confluent.connect.jdbc.util.CachedConnectionProvider.newConnection(CachedConnectionProvider.java:85)
    at io.confluent.connect.jdbc.util.CachedConnectionProvider.getValidConnection(CachedConnectionProvider.java:68)
    at io.confluent.connect.jdbc.sink.JdbcDbWriter.write(JdbcDbWriter.java:56)
    at io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:69)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:495)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:288)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:198)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:166)
    at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)
    at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)

Sink.properties: 

name=test-sink
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
tasks.max=1
topics=fp_test
connection.url=jdbc:postgresql://localhost:5432/casb
connection.user=admin
connection.password=***
auto.create=true

Я установил plugin.path=/usr/share/java/kafka-connect-jdbc

Вкл. / usr / share / java / kafka-connect-jdbc У меня есть следующие файлы:

kafka-connect-jdbc-4.0.0.jar, postgresql-9.4-1206-jdbc41.jar, sqlite-jdbc-3.8.11.2.jar и некоторые другие jar-файлы, которые в основном поставляются вместе с confluent.

Затем я скачал jar-драйвер postgres-jdbc postgresql-42.2.2.jar, скопировал его в ту же папку и попыталсяснова.Всё то же исключение.

Пожалуйста, помогите мне с этим.

Ответы [ 2 ]

0 голосов
/ 15 июня 2019

Я получаю ту же ошибку в распределенном режиме kafka connect.

** Используя пример https://github.com/debezium/debezium-examples/tree/master/tutorial#using-postgres ссылка *

шагов:

{

} 1 разъем источника 2 Подробности конфигурации разъема раковины приведены ниже:

enter image description here

0 голосов
/ 25 июня 2018

Настройка plugin.path=/usr/share/java и CLASSPATH=/usr/share/java/kafka-connect-jdbc/ решили проблему.

...