Я пытаюсь создать соединитель Kafka и передать секреты, которые используются для создания соединителя через конечную точку / соединители REST
Я следовал KIP-297 , чтобы построить Кафку Connector.
Также я следовал решению, упомянутому в этой проблеме .
Я мог видеть, что мой пользовательский класс конфигурации может загружать секреты из хранилища, когда конструктор получает выполняется при запуске приложения. Но когда я запускаю запрос почтальона в конечную точку REST для создания соединителя, секреты не загружаются. Я попытался отладить и обнаружил, что ни один из перечисленных ниже переопределенных методов не вызывается при создании соединителя.
public ConfigData get(String s)
public ConfigData get(String s, Set<String> param)
Я полагаю, что эти два метода отвечают за выбор фактического значения секретного ключа, упомянутого в запросе json, и замену его в фактическом запросе во время выполнения.
Я действительно не могу найти причину, по которой эти методы не вызываются или они не предназначены для вызова, а секреты загружаются другим способом
Я перешел по ссылкам выше к слову «строить» пользовательский конфиг. У меня есть свойства, установленные в distrib.properties
config.providers=env
config.providers.env.class=com.test.kafka.config.EnvConfigProvider
. У меня установлен путь к плагину в правильном каталоге, в котором находится мой jar-файл. У меня также есть полное имя пути в f ie в META-. INF.services, как упомянуто в статьях выше.
Может кто-то пролить свет на то, почему я вижу конструктор моего пользовательского класса конфигурации, загруженного при запуске, но не может загрузить секреты при запуске конечной точки REST.
Спасибо