??????flink on yarn????????kerberos??kafka

Sat, 09 May 2020 01:07:02 -0700 

krb5.conf??????????????????????????????????FLINK_ENV_JAVA_OPTS=-Djava.security.krb5.conf=xxxxx/krb5.conf




------------------ ???????? ------------------
??????: "zjfpla...@hotmail.com"<zjfpla...@hotmail.com&gt;; 
????????: 2020??5??9??(??????) ????4:00
??????: "user-zh"<user-zh@flink.apache.org&gt;; 
????: flink on yarn????????kerberos??kafka



????????
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ????????flink on 
yarn????????????kerberos??kafka??????????sink??????kerberos??hbase
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
????????????flink-conf.yaml??????????????????
security.kerberos.login.use-ticket-cache: false
security.kerberos.login.keytab: /home/zjf/zjf.keytab
security.kerberos.login.principal: zjf@TDH
security.kerberos.login.contexts: Client,KafkaClient
zookeeper.sasl.service-name: zookeeper
zookeeper.sasl.login-context-name: Client
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
??????keytab????????????????????kafka??????????????shell????????????????????flink??????????????????org.apache.kafka.common.errors.TimeoutException:
 Timeout expired while fetching topic metadata??????????????????

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
????????????????yaml??????????????????
env.java.opts.jobmanager: -Djava.security.auth.login.config=/home/zjf/jaas.conf 
-Djava.security.krb5.conf=/home/zjf/krb5.conf -Dsun.security.krb5.debug=true
env.java.opts.taskmanager: 
-Djava.security.auth.login.config=/home/zjf/jaas.conf 
-Djava.security.krb5.conf=/home/zjf/krb5.conf&nbsp; 
-Dsun.security.krb5.debug=true
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ??????????cannot locate default 
realm??????

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; flink??????1.8.1



zjfpla...@hotmail.com

回复