Flink访问带kerberos认证的kafka: Can‘t get Master Kerberos principal for use as renewer

Failed with exception java.io.IOException:java.io.IOException: Can't get Master Kerberos    principal for use as renewer

在yarn-site.xml

中添加以下配置

<property>
    <name>yarn.nodemanager.principal</name>
    <value>xxx_priciple/fqdn@_HOST</value>
</property>
<property>
    <name>yarn.resourcemanager.principal</name>
    <value>xxx_priciple/fqdn@_HOST</value>
</property>
版权声明：本文为qq_38349554原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。