Может ли Kafka Connector загружать свое собственное имя?

Question

Согласно документации Кафки

Конфигурации соединителя представляют собой простые сопоставления ключ-значение. Для автономного режим они определены в файле свойств и передаются в Connect процесс в командной строке.

Большинство конфигураций зависят от разъема, поэтому их нельзя очертить Вот. Однако есть несколько распространенных вариантов:

name - Unique name for the connector. Attempting to register again with the same name will fail.

У меня есть 10 разъемов, работающих в автономном режиме, например:

bin/connect-standalone.sh config/connect-standalone.properties connector1.properties connector2.properties ...

Мой вопрос: может ли соединитель загрузить свое собственное имя во время выполнения?

Заранее спасибо.

Answer 1

Да, вы можете получить имя соединителя во время выполнения.

При запуске соединителя все свойства передаются Connector::start(Map<String, String> props).Соединитель может читать эти свойства, проверять их, сохранять и затем передавать на Task.От реализации Коннектора зависит, использует он его или нет.

Свойство имени коннектора равно name.