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

Question

Я использую kafka-connect-elasticsearch с пользовательским конвертером, который расширяет стандарт org.apache.kafka.connect.json.JsonConverter.

В моем пользовательском конвертере мне нужно получить доступ к переменной окружения.
Предположим, мне нужно добавитькаждому сообщению имя кластера, которое записывается в переменную окружения CLUSTER.

Как получить доступ к переменной окружения в преобразователе?
Может быть, прочитать ее на этапе настройки преобразователя (configure(Map<String, ?> configs)methond)?
Как переслать CLUSTER значение переменной env на эту configs карту?

Answer 1

Вы не можете получить это на этой карте.

Вам нужно будет использовать System.getenv("CLUSTER")