в myconnector.properties файле. Как можно дальше запустить коннектор?
А Вы kafka connect запускаете в standalone или distributed mode?
Скорее всего distributed mode. А в каком обычно конфиг файле указывется?
тогда коннектор нужно создавать не в файле, а через REST API kafka connect в дистрибютед режиме конфиги сохраняются в топике в самой кафке
Просто прежние все созданы в файлах .properties
Там когда через пост передавать в json объекте, в config что писать?
То же что в файле, только в json
Точно, спасибо.
выходит другой вопрос по этому же "database.user":"${file:/opt/kafka/connect-secrets.properties:username}", "database.password":"${file:/opt/kafka/connect-secrets.properties:password}" добавляю пользователя внешне, выводит ошибку пользователя. Будто не поддерживает провайдер FileConfigProvider
Мы так и не научились пробрасывать туда переменные. Явно указываем пароли
Обсуждают сегодня