Как добавить kafka-connect-jdb c -5.5.0.jar в Debezium / connect

Question

Я загрузил файл kafka-connect-jdb c -5.5.0.jar из confluent на мою локальную машину. Я хотел бы знать, как добавить эту банку в plugin.path = / kafka / connect. Я пытаюсь передать данные на сервер mysql, поэтому я использую «connector.class»: «io.confluent.connect.jdb c .JdbcSinkConnector», но я сталкиваюсь с «error_code»: 500, «message»: "Не удалось найти класс, который реализует Connector и имя которого соответствует io.confluent.connect.jdb c .JdbcSinkConnector, я использую docker набор инструментов на windows машине

Answer 1

Пожалуйста, проверьте этот экзамен Dockerfile . Он демонстрирует, как развернуть соединитель приемника для JDB C и Elasticsearch. Как правило, наиболее важно помнить, что если plagin.path установлен на /kafka/connect, то соединитель, но будет развернут в каталоге с именем /kafka/connect/<arbitrary_name_dirname>.