Hello I am trying to run KafkaServer v3.9.1 in Kraft mode by setting node.id and process.roles to ‘broker,controller’. However, I see errors related to zookeeper.connect because KafkaServer is trying to connect to a non-existent zookeeper.
https://github.com/a0x8o/kafka/blob/54eff6af115ee647f60129f2ce6a044cb17215d0/core/src/main/scala/kafka/server/KafkaServer.scala#L219 Shouldn’t the KafkaServer not try to connect to zookeeper when we are trying to use broker-controller combination? [L4J2-test] 10:33:06 ERROR: kafka.server.KafkaServer - Fatal error during KafkaServer startup. Prepare to shutdown java.lang.NullPointerException: null at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:2301) ~[kafka_2.13-3.9.1.jar:?] at kafka.zk.KafkaZkClient$.createZkClient(KafkaZkClient.scala:2407) ~[kafka_2.13-3.9.1.jar:?] at kafka.server.KafkaServer.initZkClient(KafkaServer.scala:754) ~[kafka_2.13-3.9.1.jar:?] at kafka.server.KafkaServer.startup(KafkaServer.scala:231) ~[kafka_2.13-3.9.1.jar:?] at test.kafka.TestKafkaCluster.start(TestKafkaCluster.java:152) ~[classes/:?] at jobs.kafka.common.KafkaUtilsITTest.testWithController(KafkaUtilsITTest.java:68) ~[test-classes/:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?] {node.id=1, retry.backoff.max.ms=5000, log.flush.interval.messages=1, reconnect.backoff.max.ms=5000, listeners=CLIENT://127.0.0.1:53519,INTERNAL://127.0.0.1:53520,CONTROLLER://127.0.0.1:53522,EXTERNAL://127.0.0.1:53521, log.flush.interval.ms=1, inter.broker.listener.name=INTERNAL, reconnect.backoff.ms=2000, retry.backoff.ms=2000, bootstrap-server=127.0.0.1:53519, retries=10, controller.quorum.voters=1@127.0.0.1:53522<mailto:controller.quorum.voters=1@192.168.1.153:53522>, process.roles=broker,controller, controller.listener.names=CONTROLLER, broker.session.timeout.ms=600000, listeners.external.bootstrap.servers=PLAINTEXT://127.0.0.1:53521, connections.max.idle.ms=600000, max.connections=10, advertised.listeners=CLIENT://127.0.0.1:53519,INTERNAL://127.0.0.1:53520,CONTROLLER://127.0.0.1:53522,EXTERNAL://127.0.0.1:53521, log.dirs=/var/folders/vq/wxftld0j1k55ggcj01cm5xqr0000gn/T/kafka-tmp-dir18134250652535898760/kafka-logs, listener.security.protocol.map=CLIENT:PLAINTEXT,INTERNAL:PLAINTEXT,CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT} Thanks Ranga
