FlinkFlink kerberos 认证报错 while accessing user/group information via Hadoop utils

Posted 2022-11-29 九师兄

文章目录

• 1.概述
• 2.提问
• 3. 源码研究
• 4. 最终解决

1.概述

flink认证报错 error while accessing user/group information via Hadoop utils 和 错误 Cannot locate default realm

整体是这样的，我FLink 消费kafka 写入 Es ，组件使用了 hadoop ,zk,es,kafka 都有kerberos认证，然后这个环境原本是认证成功的，然后现在哟啊关闭kafka kerberos认证了。

我写了一个配置 是 kafka.kerberos.enable=true 的时候 执行提交脚本的时候是带 kerberos参数的 但是我们这个环境变动了

原先说好的 kafka是必须开启kerberos的 但是最近下游人家对接kafka总是卡 特别麻烦 然后他们又决定不开kafka了

# 是否开启kafka的kerberos的认证

kafka.kerberos.enable&#