[
https://issues.apache.org/jira/browse/KAFKA-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626261#comment-17626261
]
Tama MA commented on KAFKA-14341:
---------------------------------
I found the reason...
{code:java}
authorizer.class.name=org.apache.kafka.metadata.authorizer.StandardAuthorizer
allow.everyone.if.no.acl.found=true {code}
hmmm...
Well, we arrive at this bug:
{code:java}
Oct 30 15:54:32 node-1 bash[1488102]: kc-data-_kafka-1 |
[2022-10-30 15:54:32,930] INFO [BrokerLifecycleManager id=1] Unable to register
broker 1 because the controller returned error UNKNOWN_SERVER_ERROR
(kafka.server.BrokerLifecycleManager)
Oct 30 15:54:33 node-1 bash[1488102]: kc-data-_kafka-1 |
[2022-10-30 15:54:33,035] ERROR [ControllerApis nodeId=1] Unexpected error
handling request RequestHeader(apiKey=BROKER_REGISTRATION, apiVersion=0,
clientId=1, correlationId=2) -- BrokerRegistrationRequestData(brokerId=1,
clusterId='i2SnxawKRQyU5m0MTYwbSg', incarnationId=sTBvHBEvT12-vqbBxTnrhA,
listeners=[Listener(name='SASL_PLAINTEXT', host='_kafka', port=9092,
securityProtocol=2)], features=[Feature(name='metadata.version',
minSupportedVersion=1, maxSupportedVersion=7)], rack=null) with context
RequestContext(header=RequestHeader(apiKey=BROKER_REGISTRATION, apiVersion=0,
clientId=1, correlationId=2), connectionId='127.0.0.1:9093-127.0.0.1:51006-0',
clientAddress=/127.0.0.1, principal=User:ANONYMOUS,
listenerName=ListenerName(CONTROLLER), securityProtocol=PLAINTEXT,
clientInformation=ClientInformation(softwareName=apache-kafka-java,
softwareVersion=3.3.1), fromPrivilegedListener=false,
principalSerde=Optional[org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder@26a12ec8])
(kafka.server.ControllerApis) {code}
> 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)
