[
https://issues.apache.org/jira/browse/KAFKA-14273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kedar Joshi updated KAFKA-14273:
--------------------------------
Description:
{{Basic cluster setup doesn't work on Windows 10.}}
*{{Steps}}*
* {{Initialize cluster with -}}
{code:sh}
bin\windows\kafka-storage.bat random-uuid
bin\windows\kafka-storage.bat format -t %cluster_id% -c
.\config\kraft\server.properties{code}
* Start Kafka with -
{code:sh}
bin\windows\kafka-server-start.bat .\config\kraft\server.properties{code}
*Stacktrace*
Kafka fails to start with following exception -
{code:java}
D:\LocationGuru\Servers\Kafka-3.3>bin\windows\kafka-server-start.bat
.\config\kraft\server.properties
[2022-10-03 23:14:20,089] INFO Registered kafka:type=kafka.Log4jController
MBean (kafka.utils.Log4jControllerRegistration$)
[2022-10-03 23:14:20,375] INFO Setting -D
jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS
renegotiation (org.apache.zookeeper.common.X509Util)
[2022-10-03 23:14:20,594] INFO [LogLoader partition=__cluster_metadata-0,
dir=D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs] Loading producer
state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-10-03 23:14:20,594] INFO [LogLoader partition=__cluster_metadata-0,
dir=D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs] Reloading from
producer snapshot and rebuilding producer state from offset 0
(kafka.log.UnifiedLog$)
[2022-10-03 23:14:20,594] INFO [LogLoader partition=__cluster_metadata-0,
dir=D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs] Producer state
recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0
(kafka.log.UnifiedLog$)
[2022-10-03 23:14:20,640] INFO Initialized snapshots with IDs SortedSet() from
D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs__cluster_metadata-0
(kafka.raft.KafkaMetadataLog$)
[2022-10-03 23:14:20,734] INFO [raft-expiration-reaper]: Starting
(kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
[2022-10-03 23:14:20,900] ERROR Exiting Kafka due to fatal exception
(kafka.Kafka$)
java.io.UncheckedIOException: Error while writing the Quorum status from the
file
D:\LocationGuru\Servers\Kafka-3.3\tmp\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:369)
at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:200)
at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:127)
at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:83)
at kafka.Kafka$.buildServer(Kafka.scala:79)
at kafka.Kafka$.main(Kafka.scala:87)
at kafka.Kafka.main(Kafka.scala)
Caused by: java.nio.file.FileSystemException:
D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs_cluster_metadata-0\quorum-state.tmp
->
D:\LocationGuru\Servers\Kafka-3.3\tmp\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:403)
at
java.base/sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:293)
at java.base/java.nio.file.Files.move(Files.java:1430)
at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:935)
at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:918)
at
org.apache.kafka.raft.FileBasedStateStore.writeElectionStateToFile(FileBasedStateStore.java:152)
... 10 more
Suppressed: java.nio.file.FileSystemException:
D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs_cluster_metadata-0\quorum-state.tmp
->
D:\LocationGuru\Servers\Kafka-3.3\tmp\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:317)
at
java.base/sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:293)
at java.base/java.nio.file.Files.move(Files.java:1430)
at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:932)
... 12 more{code}
*Environment*
Windows 10 (64 bit)
was:
{{Basic cluster setup doesn't work on Windows 10.}}
*{{Steps}}*
* {{Initialize cluster with -}}
{{ bin\windows\kafka-storage.bat random-uuid}}
{{ bin\windows\kafka-storage.bat format -t %cluster_id% -c
.\config\kraft\server.properties}}
* Start Kafka with -
{{ bin\windows\kafka-server-start.bat .\config\kraft\server.properties}}
*Stacktrace*
Kafka fails to start with following exception -
{{D:\LocationGuru\Servers\Kafka-3.3>bin\windows\kafka-server-start.bat
.\config\kraft\server.properties}}
{{[2022-10-03 23:14:20,089] INFO Registered kafka:type=kafka.Log4jController
MBean (kafka.utils.Log4jControllerRegistration$)}}
{{[2022-10-03 23:14:20,375] INFO Setting -D
jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS
renegotiation (org.apache.zookeeper.common.X509Util)}}
{{[2022-10-03 23:14:20,594] INFO [LogLoader partition=__cluster_metadata-0,
dir=D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs] Loading producer
state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)}}
{{[2022-10-03 23:14:20,594] INFO [LogLoader partition=__cluster_metadata-0,
dir=D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs] Reloading from
producer snapshot and rebuilding producer state from offset 0
(kafka.log.UnifiedLog$)}}
{{[2022-10-03 23:14:20,594] INFO [LogLoader partition=__cluster_metadata-0,
dir=D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs] Producer state
recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0
(kafka.log.UnifiedLog$)}}
{{[2022-10-03 23:14:20,640] INFO Initialized snapshots with IDs SortedSet()
from
D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs__cluster_metadata-0
(kafka.raft.KafkaMetadataLog$)}}
{{[2022-10-03 23:14:20,734] INFO [raft-expiration-reaper]: Starting
(kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)}}
{{[2022-10-03 23:14:20,900] ERROR Exiting Kafka due to fatal exception
(kafka.Kafka$)}}
{{java.io.UncheckedIOException: Error while writing the Quorum status from the
file
D:\LocationGuru\Servers\Kafka-3.3\tmp\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:369)}}
{{ at
kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:200)}}
{{ at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:127)}}
{{ at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:83)}}
{{ at kafka.Kafka$.buildServer(Kafka.scala:79)}}
{{ at kafka.Kafka$.main(Kafka.scala:87)}}
{{ at kafka.Kafka.main(Kafka.scala)}}
{{Caused by: java.nio.file.FileSystemException:
D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs__cluster_metadata-0\quorum-state.tmp
->
D:\LocationGuru\Servers\Kafka-3.3\tmp\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:403)}}
{{ at
java.base/sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:293)}}
{{ at java.base/java.nio.file.Files.move(Files.java:1430)}}
{{ at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:935)}}
{{ at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:918)}}
{{ at
org.apache.kafka.raft.FileBasedStateStore.writeElectionStateToFile(FileBasedStateStore.java:152)}}
{{ ... 10 more}}
{{ Suppressed: java.nio.file.FileSystemException:
D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs__cluster_metadata-0\quorum-state.tmp
->
D:\LocationGuru\Servers\Kafka-3.3\tmp\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:317)}}
{{ at
java.base/sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:293)}}
{{ at java.base/java.nio.file.Files.move(Files.java:1430)}}
{{ at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:932)}}
{{ ... 12 more}}
*Environment*
Windows 10 (64 bit)
> Kafka doesn't start with KRaft on Windows
> -----------------------------------------
>
> Key: KAFKA-14273
> URL: https://issues.apache.org/jira/browse/KAFKA-14273
> Project: Kafka
> Issue Type: Bug
> Components: kraft
> Affects Versions: 3.3.1
> Reporter: Kedar Joshi
> Priority: Major
>
> {{Basic cluster setup doesn't work on Windows 10.}}
> *{{Steps}}*
> * {{Initialize cluster with -}}
> {code:sh}
> bin\windows\kafka-storage.bat random-uuid
> bin\windows\kafka-storage.bat format -t %cluster_id% -c
> .\config\kraft\server.properties{code}
>
> * Start Kafka with -
> {code:sh}
> bin\windows\kafka-server-start.bat .\config\kraft\server.properties{code}
>
> *Stacktrace*
> Kafka fails to start with following exception -
> {code:java}
> D:\LocationGuru\Servers\Kafka-3.3>bin\windows\kafka-server-start.bat
> .\config\kraft\server.properties
> [2022-10-03 23:14:20,089] INFO Registered kafka:type=kafka.Log4jController
> MBean (kafka.utils.Log4jControllerRegistration$)
> [2022-10-03 23:14:20,375] INFO Setting -D
> jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated
> TLS renegotiation (org.apache.zookeeper.common.X509Util)
> [2022-10-03 23:14:20,594] INFO [LogLoader partition=__cluster_metadata-0,
> dir=D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs] Loading
> producer state till offset 0 with message format version 2
> (kafka.log.UnifiedLog$)
> [2022-10-03 23:14:20,594] INFO [LogLoader partition=__cluster_metadata-0,
> dir=D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs] Reloading from
> producer snapshot and rebuilding producer state from offset 0
> (kafka.log.UnifiedLog$)
> [2022-10-03 23:14:20,594] INFO [LogLoader partition=__cluster_metadata-0,
> dir=D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs] Producer state
> recovery took 0ms for snapshot load and 0ms for segment recovery from offset
> 0 (kafka.log.UnifiedLog$)
> [2022-10-03 23:14:20,640] INFO Initialized snapshots with IDs SortedSet()
> from
> D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs__cluster_metadata-0
> (kafka.raft.KafkaMetadataLog$)
> [2022-10-03 23:14:20,734] INFO [raft-expiration-reaper]: Starting
> (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
> [2022-10-03 23:14:20,900] ERROR Exiting Kafka due to fatal exception
> (kafka.Kafka$)
> java.io.UncheckedIOException: Error while writing the Quorum status from the
> file
> D:\LocationGuru\Servers\Kafka-3.3\tmp\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:369)
> at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:200)
> at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:127)
> at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:83)
> at kafka.Kafka$.buildServer(Kafka.scala:79)
> at kafka.Kafka$.main(Kafka.scala:87)
> at kafka.Kafka.main(Kafka.scala)
> Caused by: java.nio.file.FileSystemException:
> D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs_cluster_metadata-0\quorum-state.tmp
> ->
> D:\LocationGuru\Servers\Kafka-3.3\tmp\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:403)
> at
> java.base/sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:293)
> at java.base/java.nio.file.Files.move(Files.java:1430)
> at
> org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:935)
> at
> org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:918)
> at
> org.apache.kafka.raft.FileBasedStateStore.writeElectionStateToFile(FileBasedStateStore.java:152)
> ... 10 more
> Suppressed: java.nio.file.FileSystemException:
> D:\LocationGuru\Servers\Kafka-3.3\tmp\kraft-combined-logs_cluster_metadata-0\quorum-state.tmp
> ->
> D:\LocationGuru\Servers\Kafka-3.3\tmp\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:317)
> at
> java.base/sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:293)
> at java.base/java.nio.file.Files.move(Files.java:1430)
> at
> org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:932)
> ... 12 more{code}
>
> *Environment*
> Windows 10 (64 bit)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
