[ 
https://issues.apache.org/jira/browse/KAFKA-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626276#comment-17626276
 ] 

Tama MA commented on KAFKA-14341:
---------------------------------

It turns out that we have to remove the old Kafka data folder - and bootstrap 
now works OK.

 

[~ijuma] - FYI

 

[~cmccabe] Hi, I saw that you are active contributor - KIP-801. Thank you!   I 
would like to indicate that your PR works OK for a clean instance bootstrapped 
from scratch. Migrating from old KRaft is not OK for me. However, as I use 
Kafka mainly as retention buffer, so removing the old instance is ok for me 
privately.

 

Enterprise-wise, deleting an old volume would require a lot of management 
approvals ... nonetheless, it works - and thank you!

> Kafka 3.3 w/KRaft - Faiiled to bootstrap Kafka server with ACL - 
> authorizer.class.name=kafka.security.authorizer.AclAuthorizer
> ------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-14341
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14341
>             Project: Kafka
>          Issue Type: Bug
>          Components: security
>    Affects Versions: 3.3.1
>            Reporter: Tama MA
>            Priority: Major
>
> server.properties
>  
> {code:java}
> listeners=PLAINTEXT://:9092,CONTROLLER://:9093
> inter.broker.listener.name=PLAINTEXT
> advertised.listeners=PLAINTEXT://_kafka:9092
> controller.listener.names=CONTROLLER
> listener.security.protocol.map=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
> authorizer.class.name=kafka.security.authorizer.AclAuthorizer {code}
> Crash during startup...
> {code:java}
> java.lang.NullPointerException: Cannot invoke "String.indexOf(String)" 
> because "connectString" is null                           
>         at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1964)            
>         at 
> kafka.security.authorizer.AclAuthorizer.configure(AclAuthorizer.scala:184)    
>           at 
> kafka.server.ControllerServer.$anonfun$startup$11(ControllerServer.scala:135) 
>          at 
> kafka.server.ControllerServer.$anonfun$startup$11$adapted(ControllerServer.scala:135)
>                          
>         at scala.Option.foreach(Option.scala:437)                             
>          at kafka.server.ControllerServer.startup(ControllerServer.scala:135) 
>           at 
> kafka.server.KafkaRaftServer.$anonfun$startup$1(KafkaRaftServer.scala:140)    
>          at 
> kafka.server.KafkaRaftServer.$anonfun$startup$1$adapted(KafkaRaftServer.scala:140)
>                  
>         at scala.Option.foreach(Option.scala:437)                             
>           at kafka.server.KafkaRaftServer.startup(KafkaRaftServer.scala:140)  
>            at kafka.Kafka$.main(Kafka.scala:109)                              
>             at kafka.Kafka.main(Kafka.scala)   {code}
> I am not using zookeeper at all.
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to