大数据集群开启了kerberos认证 TM上kafka连接不上

Thu, 10 Oct 2019 03:01:46 -0700 

 @[email protected] :
      CDH集群kafka认证协议选择是： SASL_PLAINTEXT
      提交FlinkPerjob任务,发现TaskManager端连接kafka没有进行认证初始化，kafka客户端连接不上broker!
  
     提交脚本如下：
   ./flink/bin/flink  run   \
   -m yarn-cluster  \
   -yD 
env.java.opts="-Djava.security.auth.login.config=/software/servers/keytab/kafka_client_jass.conf"
 \
   -yqu root.budata.ads  \
   -c $clazz  $jar_path 


请问有什么解决方案样例没？

回复