[
https://issues.apache.org/jira/browse/KAFKA-13909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539086#comment-17539086
]
Andrew Grant commented on KAFKA-13909:
--------------------------------------
Thanks for the report [~fblumenstein]. Did this occur when running a co-located
node? i.e. process.roles set to broker,controller
> 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
> 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)
