Hi folks,
How can I replace the old user with new in the Zookeeper client connection.
Here is my existing jaas files:
Kafka jaas config file:
// Kafka server authentication
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username=“admin”
password=“Password1”
user_alice=“Password1”
user_bob=“Password1”;
};
// Zookeeper client authentication
Client {
org.apache.kafka.common.security.plain.PlainLoginModule required
username=“client1”
password=“Password1”;
};
Zookeeper jaas config file:
Server {
org.apache.zookeeper.server.auth.DigestLoginModule required
user_admin=“Password1”
user_client1=“Password1”;
};
When I replace ‘client1’ user with new one on both Zookeeper and Kafka jaas file, I receive following error from Brokers:
INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient)
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:566)
at kafka.zk.KafkaZkClient.createRecursive(KafkaZkClient.scala:1728)
at kafka.zk.KafkaZkClient.makeSurePersistentPathExists(KafkaZkClient.scala:1626)
at kafka.zk.KafkaZkClient.$anonfun$createTopLevelPaths$1(KafkaZkClient.scala:1618)
at kafka.zk.KafkaZkClient.$anonfun$createTopLevelPaths$1$adapted(KafkaZkClient.scala:1618)
at scala.collection.immutable.List.foreach(List.scala:333)
at kafka.zk.KafkaZkClient.createTopLevelPaths(KafkaZkClient.scala:1618)
at kafka.server.KafkaServer.initZkClient(KafkaServer.scala:501)
at kafka.server.KafkaServer.startup(KafkaServer.scala:203)
at kafka.Kafka$.main(Kafka.scala:109)
at kafka.Kafka.main(Kafka.scala)
I would be appreciate for any suggestion