Как получить токен kafkadelegation от oozie creds, перешел в действие Java ⇐ JAVA

[Anonymous]

У меня есть кафка, настроенная через аутентификацию Kerberos.
У меня есть принципала и Keytab, которая имеет доступ к кластеру. < /p>
Я добавил это в рабочий процесс: < / / p>




oozie.kafka.bootstrap.servers
hostedkafka:669


oozie.kafka.sasl.kerberos.service.name
kafka


oozie.kafka.security.protocol
SASL_PLAINTEXT


oozie.kafka.sasl.mechanism
GSSAPI


oozie.authentication.kerberos.keytab
/user/svc/private.keytab


oozie.authentication.kerberos.principal
svcd@PRIVATEXYZ.COM







${jobTracker}
${nameNode}
HelloWorld
hdfs:///user/sample/lib/HelloWorld.jar






Workflow failed




< /code>
Я борюсь за то, как будет работать аутентификация, как мне получить доступ к токену kafka_delegation, генерируемому рабочим потоком. Я попробовал это < /p>
String KAFKA_DELEGATION_TOKEN = System.getenv("KAFKA_DELEGATION_TOKEN");


Но это пусто. contry-us/iaas/content/bigdata/hadoop-odh-oozie-acquire-del-token-create-client.htm
Я попытался настроить Конфигурация JAAS с принципом и пути KeyTab, но она не работала < /p>
ошибка < /p>
Caused by: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set
at org.apache.kafka.common.security.JaasContext.defaultContext(JaasContext.java:131)
at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:96)
at org.apache.kafka.common.security.JaasContext.loadClientContext(JaasContext.java:82)
at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:167)
at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:81)
at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:105)
at org.apache.kafka.clients.producer.KafkaProducer.newSender(KafkaProducer.java:484)
at org.apache.kafka.clients.producer.KafkaProducer.(KafkaProducer.java:428)


Подробнее здесь: https://stackoverflow.com/questions/794 ... ava-action