来自KAFKA KRB5 Kerberos问题的FLINK流


0

我正在尝试使用以下方法从flink kafkaconsumer传输数据:

在这里,我的KAFKA是Kerberos安全的和SSL启用的。

我在emr5.31上运行我的Flink streaming in yarn集群。

我得到以下与领域KRB5相关的错误。

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?

1 答案


0

已经把目录conf/using--yarn ship发过去了。这个conf文件夹中有krb5.conf

最后,当我从 Flink那里传过来的时候-确认.yaml相对路径。如下所示:

环境java.opts job经理:-Djava.security.krb5.conf=./conf/krb5.conf

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


我来回答

写文章

提问题

面试题