[
https://issues.apache.org/jira/browse/KAFKA-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626276#comment-17626276
]
Tama MA edited comment on KAFKA-14341 at 10/30/22 5:57 PM:
-----------------------------------------------------------
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!
Really really good news that I can get rid of that Zookeeper. Honestly, having
another JVM just fof ZK metadata really makes no sense. ACL is the last piece
of puzzle to be solved, since integratioon with LDAP is a must at enterprise.
was (Author: JIRAUSER297683):
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)
