Hi *Team*,
I am following the steps mentioned here https://kafka.apache.org/quickstart
to Install the Kafka.
*Windows* 11
*Kafka Version*
https://www.apache.org/dyn/closer.cgi?path=/kafka/3.5.0/kafka_2.13-3.5.0.tgz
*64 Bit Operating System*
*Step1: Generate the Cluster UUID*
$KAFKA_CLUSTER_ID=.\bin\windows\kafka-storage.bat random-uuid
*Step2: Format Log Directories*
.\bin\windows\kafka-storage.bat format -t $KAFKA_CLUSTER_ID -c
.\config\kraft\server.properties
*Step3: Start the Kafka Server*
.\bin\windows\kafka-server-start.bat .\config\kraft\server.properties
I am getting the error. Logs are attached
Could you please help me to sort this error.
Kindly let me know, if you need any more information.
-
Best
Sumanshu Nankana
[2023-09-04 22:16:25,770] INFO Initialized snapshots with IDs SortedSet() from
C:\Users\suman\Downloads\kafka\.\data\kraft-combined-logs\__cluster_metadata-0
(kafka.raft.KafkaMetadataLog$)
[2023-09-04 22:16:25,802] INFO [raft-expiration-reaper]: Starting
(kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
[2023-09-04 22:16:25,973] ERROR [SharedServer id=1] Got exception while
starting SharedServer (kafka.server.SharedServer)
java.io.UncheckedIOException: Error while writing the Quorum status from the
file
C:\Users\suman\Downloads\kafka\.\data\kraft-combined-logs\__cluster_metadata-0\quorum-state
at
org.apache.kafka.raft.FileBasedStateStore.writeElectionStateToFile(FileBasedStateStore.java:155)
at
org.apache.kafka.raft.FileBasedStateStore.writeElectionState(FileBasedStateStore.java:128)
at org.apache.kafka.raft.QuorumState.transitionTo(QuorumState.java:477)
at org.apache.kafka.raft.QuorumState.initialize(QuorumState.java:212)
at
org.apache.kafka.raft.KafkaRaftClient.initialize(KafkaRaftClient.java:370)
at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:248)
at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:174)
at kafka.server.SharedServer.start(SharedServer.scala:247)
at kafka.server.SharedServer.startForController(SharedServer.scala:129)
at kafka.server.ControllerServer.startup(ControllerServer.scala:197)
at
kafka.server.KafkaRaftServer.$anonfun$startup$1(KafkaRaftServer.scala:95)
at
kafka.server.KafkaRaftServer.$anonfun$startup$1$adapted(KafkaRaftServer.scala:95)
at scala.Option.foreach(Option.scala:437)
at kafka.server.KafkaRaftServer.startup(KafkaRaftServer.scala:95)
at kafka.Kafka$.main(Kafka.scala:113)
at kafka.Kafka.main(Kafka.scala)
Caused by: java.nio.file.FileSystemException:
C:\Users\suman\Downloads\kafka\.\data\kraft-combined-logs\__cluster_metadata-0\quorum-state.tmp
->
C:\Users\suman\Downloads\kafka\.\data\kraft-combined-logs\__cluster_metadata-0\quorum-state:
The process cannot access the file because it is being used by another process
at
java.base/sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:92)
at
java.base/sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:103)
at java.base/sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:414)
at
java.base/sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:291)
at java.base/java.nio.file.Files.move(Files.java:1429)
at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:950)
at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:933)
at
org.apache.kafka.raft.FileBasedStateStore.writeElectionStateToFile(FileBasedStateStore.java:152)
... 15 more
Suppressed: java.nio.file.FileSystemException:
C:\Users\suman\Downloads\kafka\.\data\kraft-combined-logs\__cluster_metadata-0\quorum-state.tmp
->
C:\Users\suman\Downloads\kafka\.\data\kraft-combined-logs\__cluster_metadata-0\quorum-state:
The process cannot access the file because it is being used by another process
at
java.base/sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:92)
at
java.base/sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:103)
at
java.base/sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:328)
at
java.base/sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:291)
at java.base/java.nio.file.Files.move(Files.java:1429)
at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:947)
... 17 more
[2023-09-04 22:16:25,973] INFO [ControllerServer id=1] Waiting for controller
quorum voters future (kafka.server.ControllerServer)
[2023-09-04 22:16:25,973] INFO [ControllerServer id=1] Finished waiting for
controller quorum voters future (kafka.server.ControllerServer)
[2023-09-04 22:16:25,989] ERROR Encountered fatal fault: caught exception
(org.apache.kafka.server.fault.ProcessTerminatingFaultHandler)
java.lang.NullPointerException: Cannot invoke
"kafka.raft.KafkaRaftManager.apiVersions()" because the return value of
"kafka.server.SharedServer.raftManager()" is null
at kafka.server.ControllerServer.startup(ControllerServer.scala:210)
at
kafka.server.KafkaRaftServer.$anonfun$startup$1(KafkaRaftServer.scala:95)
at
kafka.server.KafkaRaftServer.$anonfun$startup$1$adapted(KafkaRaftServer.scala:95)
at scala.Option.foreach(Option.scala:437)
at kafka.server.KafkaRaftServer.startup(KafkaRaftServer.scala:95)
at kafka.Kafka$.main(Kafka.scala:113)
at kafka.Kafka.main(Kafka.scala)
