Kafka Connect не удалось добавить MySqlConnector
Мне нужна чья-то помощь.
Я следую учебному пособию Потоковая передача данных из MySQL в Kafka с Kafka Connect и Debezium, но у меня возникают проблемы с подключением MySql к серверу Kafka с использованием Debezium MySQL Connector.
Вот мои настройки и другая информация.
ОС: Windows 10.
Kafka Connect: Confluent 5.0.
MySQL Connector: 0.8.1 Final.
Я храню файлы
,
Я добавляю путь к плагинам
Когда я попытался подключиться к Kafka Connect, он вернул мне ошибку. "Не удалось найти любой класс, который реализует Connector и имя которого соответствует io.debezium.connector.mysql.MySqlConnector"
Я что-то пропустил? Кто-нибудь может помочь?
2 ответа
Убедитесь, что вы поместили файл соединителя.jar в plugins.path который определяется в свойствах kafka-connect и обычно отображается на /usr/share/java,
После добавления соединителя в правильный каталог вам нужно либо загрузить соединитель, либо перезапустить kafka-connect, чтобы он автоматически загружался при запуске.
Ваш путь к плагину неверен (confluent-5.0.0\share\java), либо он должен начинаться с / (что означает корень текущего диска), либо вы должны указать полный путь.
Это причина, по которой разъем jar отсутствует в classpath