在Flink的flinkconf.xml配置文件中添以下配置(代码中不用添加任何东西,亲测有效) ,Flink的官网上也有相关内容的讲解,在Kafka这个目录中有关于Kerberos的讲解. security.kerberos.login.use-ticket-cache: true security.kerberos.login.keytab: /home/hadoop/hadoop.keytab security.kerberos.login.principal: hadoop@EXAMPLE.COM env.java.opts: -Djava.security.krb5.conf=/etc/krb5.conf security.kerberos.login.contexts: client
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)