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)