Member since
10-27-2020
2
Posts
1
Kudos Received
0
Solutions
08-22-2021
10:56 PM
1 Kudo
flink配置文件中默认配置了security.kerberos.login.contexts: Client,KafkaClient,取消对应的配置就可以正常执行了。
... View more
08-12-2021
04:37 AM
我在一个启用了kerberos的CDH6.3集群里,提交一个flink1.9版本程序到yarn,需消费集群外一个0.8版本的未启用安全认证的kafka,需要如何设置他不使用安全的方式去连接这个集群外kafka的zookeeper呢?谢谢。 org.apache.flink.shaded.zookeeper.org.apache.zookeeper.client. ZooKeeperSaslClient - Client will use GSSAPI as SASL mechanism. org.apache.flink.shaded.zookeeper.org.apache.zookeeper. ClientCnxn - Opening socket connection to server ark1.analysys.xyz/ 10.2 . 33.189 : 2181 . Will attempt to SASL -authenticate using Login Context section 'Client' org.apache.flink.shaded.zookeeper.org.apache.zookeeper.client. ZooKeeperSaslClient - An error: (java.security. PrivilegedActionException : javax.security.sasl. SaslException : GSS initiate failed [ Caused by GSSException : No valid credentials provided ( Mechanism level: Server not found in Kerberos database ( 7 ) - LOOKING_UP_SERVER )]) occurred when evaluating Zookeeper Quorum Member 's received SASL token. Zookeeper Client will go to AUTH_FAILED state.
... View more
Labels:
- Labels:
-
Apache Flink
-
Apache Kafka