Я пытаюсь написать собственный исходный соединитель для kafka connect, и мне требуется написать в нем простого простого производителя kafka (который не имеет отношения ни к одному из свойств соединителя). Требуется отправлять сообщения оплохие записи, с которыми я сталкиваюсь и отправляю их в другую тему с помощью простого производителя.
Итак, чтобы запустить производителя, мне нужен конфигурационный файл bootstrapserver , который изначально использовался для запуска работника соединения.
Возможно ли динамическое чтение работника соединенияконфиг внутри разъема?