[ https://issues.apache.org/jira/browse/KAFKA-13909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541996#comment-17541996 ]
Andrew Grant commented on KAFKA-13909: -------------------------------------- https://issues.apache.org/jira/browse/KAFKA-13937 looks similar > Restart Kafka in KRaft mode with ACLs ends in a RuntimeException > ---------------------------------------------------------------- > > Key: KAFKA-13909 > URL: https://issues.apache.org/jira/browse/KAFKA-13909 > Project: Kafka > Issue Type: Bug > Components: kraft > Affects Versions: 3.2.0 > Environment: Running Kafka in a Docker container > Reporter: Florian Blumenstein > Assignee: Luke Chen > Priority: Major > Attachments: kafka.log, server.properties > > > Running Kafka in KRaft mode works for the initial startup. When restarting > Kafka it ends in a RuntimeException: > [2022-05-17 08:26:40,959] ERROR [BrokerServer id=1] Fatal error during broker > startup. Prepare to shutdown (kafka.server.BrokerServer) > java.util.concurrent.ExecutionException: java.lang.RuntimeException: An ACL > with ID toAvM0TbTfWRmS1kjknRaA already exists. > at java.base/java.util.concurrent.CompletableFuture.reportGet(Unknown > Source) > at java.base/java.util.concurrent.CompletableFuture.get(Unknown > Source) > at kafka.server.BrokerServer.startup(BrokerServer.scala:426) > at > kafka.server.KafkaRaftServer.$anonfun$startup$2(KafkaRaftServer.scala:114) > at > kafka.server.KafkaRaftServer.$anonfun$startup$2$adapted(KafkaRaftServer.scala:114) > at scala.Option.foreach(Option.scala:437) > at kafka.server.KafkaRaftServer.startup(KafkaRaftServer.scala:114) > at kafka.Kafka$.main(Kafka.scala:109) > at kafka.Kafka.main(Kafka.scala) > Caused by: java.lang.RuntimeException: An ACL with ID toAvM0TbTfWRmS1kjknRaA > already exists. > at > org.apache.kafka.metadata.authorizer.StandardAuthorizerData.addAcl(StandardAuthorizerData.java:169) > at > org.apache.kafka.metadata.authorizer.StandardAuthorizer.addAcl(StandardAuthorizer.java:83) > at > kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$19(BrokerMetadataPublisher.scala:234) > at java.base/java.util.LinkedHashMap$LinkedEntrySet.forEach(Unknown > Source) > at > kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18(BrokerMetadataPublisher.scala:232) > at > kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18$adapted(BrokerMetadataPublisher.scala:221) > at scala.Option.foreach(Option.scala:437) > at > kafka.server.metadata.BrokerMetadataPublisher.publish(BrokerMetadataPublisher.scala:221) > at > kafka.server.metadata.BrokerMetadataListener.kafka$server$metadata$BrokerMetadataListener$$publish(BrokerMetadataListener.scala:258) > at > kafka.server.metadata.BrokerMetadataListener$StartPublishingEvent.run(BrokerMetadataListener.scala:241) > at > org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:121) > at > org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:200) > at > org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:173) > at java.base/java.lang.Thread.run(Unknown Source) -- This message was sent by Atlassian Jira (v8.20.7#820007)