[
https://issues.apache.org/jira/browse/KAFKA-16145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-16145:
--------------------------------
Component/s: core
(was: connect)
> Windows Kafka Shutdown
> ----------------------
>
> Key: KAFKA-16145
> URL: https://issues.apache.org/jira/browse/KAFKA-16145
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 3.6.0
> Environment: windows, openjdk-21, kafka_2.12-3.6.0
> Reporter: user017
> Priority: Major
> 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)
