ConsumeKafka_2_0 от NiFi, поддерживающий JAAS SASL с ScramLoginModule - PullRequest
Новая
       37

ConsumeKafka_2_0 от NiFi, поддерживающий JAAS SASL с ScramLoginModule

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

Я прошел документацию ConsumeKafka_2_0 .Однако не ясно, как настроить потребителя Kafka с JAAS SASL, специфичным для ScramLoginModule.Я попытался выполнить шаги, описанные для PlainLoginModule, которые указаны на странице дополнительная информация .NiFi выдает ошибку, говоря,

Не удалось построить Kafka Consumer

1 Ответ

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

Вам потребуется создать файл JAAS с содержимым, таким как: 

KafkaClient {
  org.apache.kafka.common.security.scram.ScramLoginModule required
  username="kafkaclient1"
  password="kafkaclient1-secret";
};

Установите системное свойство в bootstrap.conf nifi, например: 

java.arg.16=-Djava.security.auth.login.config=/path/to/kafka_client_jaas.conf

Затем в процессоре вам нужнодобавить пользовательское свойство с именем «sasl.mechanism» и установить значение «SCRAM-SHA-256».

Если это не сработает, предоставьте полную трассировку стека ошибки от nifi.app.log и показать конфигурацию процессора ConsumeKafka_2_0.

...