Как настроить mongo-kafka-connect? - PullRequest
Новая
       52

Как настроить mongo-kafka-connect?

0 голосов
/ 22 октября 2019

Я не использую слияние, я могу запустить Zookeeper и Kafka успешно. И следуя инструкциям Mongo-kafka подключиться с помощью файла JAR, и я получаю сообщение об ошибке. Нужно ли мне регистрироваться после загрузки файла mongo-kafka-connect-0.2-all.jar с сайта maven tech? Я правильно обновил путь к плагину. Может кто-то помочь мне, пожалуйста? 

com.mongodb.kafka.connect.MongoSinkConnectorINFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56)
[2019-10-22 03:16:02,713] ERROR Failed to create job for config/MongoSinkConnector.properties (org.apache.kafka.connect.cli.ConnectStandalone:110)
[2019-10-22 03:16:02,714] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:121)
java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches com.mongodb.kafka.connect.MongoSinkConnector, available connectors are: PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSinkConnector,

1 Ответ

0 голосов
/ 22 октября 2019

У вас есть ошибка, потому что Kafka Connect не загрузил JAR-файл соединителя, который вы пытаетесь использовать: 

Failed to find any class that implements Connector and which name matches com.mongodb.kafka.connect.MongoSinkConnector

Один из возможных вариантов - использовать инструмент Confluent Hub установить соединитель - вы можете использовать его, не запуская Confluent Platform IIRC: 

confluent-hub install mongodb/kafka-connect-mongodb:0.2

Инструмент Confluent Hub обрабатывает такие вещи, как plugin.path, автоматически, так что вам не нужно это делать.

Кроме того, вы можете настроить его самостоятельно. Убедитесь, что plugin.path для ваших рабочих Kafka Connect настроено на включение папки, в которой находится JAR-файл коннектора приемника MongoDB.

...