Kafka Broker SASL - NoAuth Exception - KeeperErrorCode NoAut



在为broker到Zookeper Authentication 实现SASL_SSL GSSAPI机制时,我在broker 2和3节点上出现了以下异常

根据SSL设置,集群配置有SASL_SSL身份验证

Broker 1运行成功,但在Broker 2和3上出现异常org.apache.zookeeper.KeeperException$NoAuthException:KeeperErrorCode=/brokers/ids 的NoAuth

你能帮忙吗,是什么原因导致经纪人关闭以下异常

例外:

ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /brokers/ids
at org.apache.zookeeper.KeeperException.create(KeeperException.java:120)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
at kafka.zookeeper.AsyncResponse.maybeThrow(ZooKeeperClient.scala:564)
at kafka.zk.KafkaZkClient.createRecursive(KafkaZkClient.scala:1898)
at kafka.zk.KafkaZkClient.makeSurePersistentPathExists(KafkaZkClient.scala:1796)
at kafka.zk.KafkaZkClient.$anonfun$createTopLevelPaths$1(KafkaZkClient.scala:1788)
at kafka.zk.KafkaZkClient.$anonfun$createTopLevelPaths$1$adapted(KafkaZkClient.scala:1788)
at scala.collection.immutable.List.foreach(List.scala:333)
at kafka.zk.KafkaZkClient.createTopLevelPaths(KafkaZkClient.scala:1788)
at kafka.server.KafkaServer.initZkClient(KafkaServer.scala:793)
at kafka.server.KafkaServer.startup(KafkaServer.scala:399)
at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)
at kafka.Kafka$.main(Kafka.scala:82)
at kafka.Kafka.main(Kafka.scala)

当您连接到zookeeper时,您会发现代理ID丢失,并与zookeepher使用的主机名发生连接错误。您需要重新创建证书,并将主机名/IP添加到您的ext文件中。

它对我有用。

最新更新