Я использую док-контейнер centOS в экземпляре ec2. Я установил Confluent, необходимые java-файлы и разместил их в нужных местах, а Kafka/ZooKeeper и т.д. Все в порядке.
Моя цель - публиковать из базы данных MySQL в Kafka. Я установил mysql-connector jdbc (mysql-connector-java.noarch), а файл jar (mysql-connector-java.jar) находится в папке с файлом jar kafka connect. Я также установил jq, потому что Confluent продолжал издеваться надо мной.
Я пытаюсь создать пользовательский соединитель для чтения из удаленной базы данных. Используя предоставленный соединитель SQLite в качестве модели (/etc/kafka-connect-jdbc/source-quickstart-sqlite.properties), я попытался создать свой собственный файл соединителя для моей базы данных mysql:
#mysql kafka publishing test
#
name=mysql-bulk-source
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=10
connection.url=jdbc:mysql://localhost:3306
mode=bulk
connection.user=kafkadbtest
connection.password=password
topic.prefix=mysql-
но когда я запускаю confluent load mysql-source -d /path/to/myfile/mysql-source.properties я не получаю выходных данных, и confluent status connectors пусты. Запуск confluent config mysql-connector -d /path/mysql-source.properties также ничего не делает, и выполнение с confluent config mysql-connector возвращает пустую конфигурацию.
Confluent connect up. У меня нет других идей о том, что попробовать. Кто-нибудь может помочь? Любая дополнительная информация о моей конфигурации, которую я должен предоставить?
(ps тега kafka нет, но, похоже, он должен быть, и мне не хватает репутации для его создания.)