KAFKA KRB5 Kerberos问题的FLINK流式传输

Question

我正试图使用以下方法从flink kafkaconsumer流式传输数据：https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html

在这里，我的KAFKA是Kerberos安全的，并且启用了SSL。

我正在EMR 5.31上运行我的Flink流式纱线集群。

我得到以下错误与REALMKRB5有关。

Caused by: org.apache.kafka.common.errors.SaslAuthenticationException:
Failed to create SaslClient with mechanism GSSAPI
Caused by: javax.security.sasl.SaslException: Failure to initialize
security context [Caused by GSSException: Invalid name provided (Mechanism
level: KrbException: Cannot locate default realm)]

我从yaml conf文件中传递了KRB5，比如：

env.java.opts.jobmanager: -Djava.security.krb5.conf=/path/krb5.conf
env.java.opts.taskmanager: -Djava.security.krb5.conf=/path/krb5.conf

我该如何解决此问题？还有其他方法可以通过KRB5吗？

Answer 1

已经使用--yarn ship运送了目录conf/using。这个conf文件夹中有krb5.conf

最后，当我用相对路径从flink-conf.yaml经过时。就像下面一样：

env.java.opts.jobmanager:-Djava.security.krb5.conf=./conf/krb5.confenv.java.opts.taskmanager:-Djava.security.krb5.conf=./conf/krb5.confenv.java.opts:-Djava.security.krb5.conf=./conf/krb5.conf

其他选项-yD对我不起作用。