Передайте Jaas Config в Nifi Consume Kafka во время выполнения - PullRequest
0 голосов
/ 18 февраля 2019

Можем ли мы передать java.security.auth.login.config, содержащий путь конфигурации JaaS, процессору потребление Kafka, используя динамическое свойство, не устанавливая его в bootstrap.conf?

Возможно ли это?

1 Ответ

0 голосов
/ 19 февраля 2019

Это невозможно.

Свойство "java.security.auth.login.config" является системным свойством JVM, поэтому его можно установить только в bootstrap.conf, и может быть задано только одно значениедля всей JVM.

Клиент Kafka принимает свойство "sasl.jaas.config", поэтому вы должны иметь возможность указать динамическое свойство в процессоре и указать его в качестве имени, а запись JAAS - в качестве значения.(не путь к файлу jaas, а фактическое содержимое записи KafkaClient).

Однако вам не нужно этого делать.Для процессоров Kafka, начиная с 0.10 и более поздних, есть свойства непосредственно в процессоре для принципала и keytab, либо есть свойство для службы учетных данных keytab.Указав принципала и таблицу ключей с помощью одного из этих подходов, он создаст для вас подходящую запись JAAS.

...