Проблема с разъемом для раковины Kafka Connect JDB C - PullRequest
Новая
       12

Проблема с разъемом для раковины Kafka Connect JDB C

0 голосов
/ 08 января 2020

Ошибка ниже, когда работает JDB C коннектор раковины 

[2020-01-08 15:05:39,271] ERROR Plugin class loader for connector: 'io.confluent.connect.jdbc.JdbcSinkConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@6f2cfcc2 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165)
[2020-01-08 15:05:39,272] INFO Finished creating connector test-sink (org.apache.kafka.connect.runtime.Worker:273)
[2020-01-08 15:05:39,273] ERROR Plugin class loader for connector: 'io.confluent.connect.jdbc.JdbcSinkConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@6f2cfcc2 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165)
[2020-01-08 15:05:39,273] INFO SinkConnectorConfig values:

Я правильно установил путь к плагину, как указано в документации.

1 Ответ

1 голос
/ 20 марта 2020

У меня была такая же проблема с тобой, и я просто решил ее. Дело в том, что вы не должны копировать файл jar коннектора в каталог kafka libs. Вы должны установить CLASSPATH во время выполнения команды следующим образом: 

env CLASSPATH=./* connect-standalone.sh $KAFKA_HOME/config/connect-standalone.properties config/quickstart-couchbase-source.properties

или установить plugin.path в рабочем файле .properties. 

plugin.path=/path_to_the_plugin_jar_file

Надеюсь, эта помощь.

...