Wie man Kafkadelegation -Token aus Oozie -Creds bekommt, die an eine Java -Aktion übergeben werden ⇐ Java

[Anonymous]

Ich habe eine Kafka über die Kerberos -Authentifizierung eingerichtet. p>

Code: Select all

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>
Ich habe Probleme damit, wie die Authentifizierung funktionieren würde. Wie kann ich auf das durch den Arbeitsfluss generierte Kafka_Delegation -Token zugreifen. Ich habe es versucht < /p>
String KAFKA_DELEGATION_TOKEN = System.getenv("KAFKA_DELEGATION_TOKEN");

Aber es ist leer. /en-us/iaas/content/bigdata/hadoop-odh-oozie-acquire-del-tekeate-create-client.htm
Ich habe versucht JAAS -Konfiguration mit dem Prinzip und dem KeyTab -Pfad, aber sie funktionierte nicht < /p>
Fehler < /p>

Code: Select all

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)