在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
