jeongbobae created KAFKA-16145:
----------------------------------
Summary: Windows Kafka Shutdown
Key: KAFKA-16145
URL: https://issues.apache.org/jira/browse/KAFKA-16145
Project: Kafka
Issue Type: Bug
Components: connect
Affects Versions: 3.6.0
Environment: windows, openjdk-21, kafka_2.12-3.6.0
Reporter: jeongbobae
Fix For: 3.6.0
ERROR Error while deleting segments for test.public.testtable-0 in dir
C:\tmp\kafka-logs (org.apache.kafka.storage.internals.log.LogDirFailureChannel)
java.nio.file.FileSystemException:
C:\tmp\kafka-logs\test.public.testtable-0\00000000000002043576.timeindex ->
C:\tmp\kafka-logs\test.public.testtable-0\00000000000002043576.timeindex.deleted:
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:1430)
at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:982)
at
org.apache.kafka.storage.internals.log.AbstractIndex.renameTo(AbstractIndex.java:227)
at
org.apache.kafka.storage.internals.log.LazyIndex$IndexValue.renameTo(LazyIndex.java:122)
at
org.apache.kafka.storage.internals.log.LazyIndex.renameTo(LazyIndex.java:202)
at kafka.log.LogSegment.changeFileSuffixes(LogSegment.scala:495)
at kafka.log.LocalLog$.$anonfun$deleteSegmentFiles$1(LocalLog.scala:917)
at
kafka.log.LocalLog$.$anonfun$deleteSegmentFiles$1$adapted(LocalLog.scala:915)
at scala.collection.immutable.List.foreach(List.scala:333)
at kafka.log.LocalLog$.deleteSegmentFiles(LocalLog.scala:915)
at kafka.log.LocalLog.removeAndDeleteSegments(LocalLog.scala:317)
at kafka.log.UnifiedLog.$anonfun$deleteSegments$2(UnifiedLog.scala:1469)
at kafka.log.UnifiedLog.deleteSegments(UnifiedLog.scala:1845)
at
kafka.log.UnifiedLog.deleteRetentionMsBreachedSegments(UnifiedLog.scala:1443)
at kafka.log.UnifiedLog.deleteOldSegments(UnifiedLog.scala:1487)
at kafka.log.LogManager.$anonfun$cleanupLogs$3(LogManager.scala:1282)
at
kafka.log.LogManager.$anonfun$cleanupLogs$3$adapted(LogManager.scala:1279)
at scala.collection.immutable.List.foreach(List.scala:333)
at kafka.log.LogManager.cleanupLogs(LogManager.scala:1279)
at
kafka.log.LogManager.$anonfun$startupWithConfigOverrides$2(LogManager.scala:562)
at
org.apache.kafka.server.util.KafkaScheduler.lambda$schedule$1(KafkaScheduler.java:150)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at
java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358)
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: java.nio.file.FileSystemException:
C:\tmp\kafka-logs\test.public.testtable-0\00000000000002043576.timeindex ->
C:\tmp\kafka-logs\test.public.testtable-0\00000000000002043576.timeindex.deleted:
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:1430)
at
org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:978)
... 25 more
ERROR Shutdown broker because all log dirs in C:\tmp\kafka-logs have failed
(kafka.log.LogManager)
{color:#172b4d}*Run in administrator mode, no processes running*{color}
{color:#172b4d}*What more can I do?*{color}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
