AccessDidiedException при переименовании каталога журнала ⇐ JAVA

[Anonymous]

Я получил AccessDeniedException Каждый раз, когда я хотел удалить тему из Кафки. Я использую двоичный файл Kafka 3.61 в версии 2.13. Я изменил местонахождение журнала Kafka на папку с именем Data внутри каталога Kafka, чтобы он не исчезал каждый раз, когда я перезагружаю свой компьютер. Основываясь на том, что я искал все это время, я уже пытался добавить полный доступ ко всем пользователям для изменения папки. Тем не менее, я все еще получаю ту же ошибку. Когда я попытался удалить тему, моя кафка потерпела неудачу и не начнусь снова, пока не опустошаю папку данных . Я должен снова предпринять эти действия, чтобы запустить мою кафку..\bin\windows\kafka-storage.bat random-uuid
.\bin\windows\kafka-storage.bat format --cluster-id [generated-uuid] --config config\kraft\server.properties
.\bin\windows\kafka-server-start.bat .\config\kraft\server.properties
< /code>
Вот моя среда: < /strong> < /p>

Adispitium java 21 < /li>
kafka 3.61, Scala 2.13 < /li>
windows 11 24h2 < /li>
< /ul>

. log:
[2025-06-28 01:57:46,089] WARN Failed atomic move of C:\Kafka\kafka\data\belajarkafka-0 to C:\Kafka\kafka\data\belajarkafka-0.71e1d715323a4fb5b2910d13879a4bcf-delete retrying with a non-atomic move (org.apache.kafka.common.utils.Utils)
java.nio.file.AccessDeniedException: C:\Kafka\kafka\data\belajarkafka-0 -> C:\Kafka\kafka\data\belajarkafka-0.71e1d715323a4fb5b2910d13879a4bcf-delete
at java.base/sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:89)
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:1431)
at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:978)
at kafka.log.LocalLog.$anonfun$renameDir$2(LocalLog.scala:111)
at kafka.log.LocalLog.renameDir(LocalLog.scala:739)
at kafka.log.UnifiedLog.$anonfun$renameDir$2(UnifiedLog.scala:676)
at kafka.log.UnifiedLog.renameDir(UnifiedLog.scala:1845)
at kafka.log.LogManager.asyncDelete(LogManager.scala:1198)
at kafka.log.LogManager.$anonfun$asyncDelete$4(LogManager.scala:1235)
at scala.Option.foreach(Option.scala:437)
at kafka.log.LogManager.$anonfun$asyncDelete$3(LogManager.scala:1233)
at kafka.log.LogManager.$anonfun$asyncDelete$3$adapted(LogManager.scala:1231)
at scala.collection.mutable.HashSet$Node.foreach(HashSet.scala:450)
at scala.collection.mutable.HashSet.foreach(HashSet.scala:376)
at kafka.log.LogManager.asyncDelete(LogManager.scala:1231)
at kafka.server.ReplicaManager.stopPartitions(ReplicaManager.scala:627)
at kafka.server.ReplicaManager.applyDelta(ReplicaManager.scala:2558)
at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$onMetadataUpdate$7(BrokerMetadataPublisher.scala:176)
at scala.Option.foreach(Option.scala:437)
at kafka.server.metadata.BrokerMetadataPublisher.onMetadataUpdate(BrokerMetadataPublisher.scala:173)
at org.apache.kafka.image.loader.MetadataLoader.maybePublishMetadata(MetadataLoader.java:341)
at org.apache.kafka.image.loader.MetadataBatchLoader.applyDeltaAndUpdate(MetadataBatchLoader.java:272)
at org.apache.kafka.image.loader.MetadataBatchLoader.maybeFlushBatches(MetadataBatchLoader.java:208)
at org.apache.kafka.image.loader.MetadataLoader.lambda$handleCommit$1(MetadataLoader.java:365)
at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:1583)
[2025-06-28 01:57:46,094] ERROR Error while renaming dir for belajarkafka-0 in log dir C:\Kafka\kafka\data (org.apache.kafka.storage.internals.log.LogDirFailureChannel)
java.nio.file.AccessDeniedException: C:\Kafka\kafka\data\belajarkafka-0 -> C:\Kafka\kafka\data\belajarkafka-0.71e1d715323a4fb5b2910d13879a4bcf-delete
at java.base/sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:89)
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:1431)
at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:982)
at kafka.log.LocalLog.$anonfun$renameDir$2(LocalLog.scala:111)
at kafka.log.LocalLog.renameDir(LocalLog.scala:739)
at kafka.log.UnifiedLog.$anonfun$renameDir$2(UnifiedLog.scala:676)
at kafka.log.UnifiedLog.renameDir(UnifiedLog.scala:1845)
at kafka.log.LogManager.asyncDelete(LogManager.scala:1198)
at kafka.log.LogManager.$anonfun$asyncDelete$4(LogManager.scala:1235)
at scala.Option.foreach(Option.scala:437)
at kafka.log.LogManager.$anonfun$asyncDelete$3(LogManager.scala:1233)
at kafka.log.LogManager.$anonfun$asyncDelete$3$adapted(LogManager.scala:1231)
at scala.collection.mutable.HashSet$Node.foreach(HashSet.scala:450)
at scala.collection.mutable.HashSet.foreach(HashSet.scala:376)
at kafka.log.LogManager.asyncDelete(LogManager.scala:1231)
at kafka.server.ReplicaManager.stopPartitions(ReplicaManager.scala:627)
at kafka.server.ReplicaManager.applyDelta(ReplicaManager.scala:2558)
at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$onMetadataUpdate$7(BrokerMetadataPublisher.scala:176)
at scala.Option.foreach(Option.scala:437)
at kafka.server.metadata.BrokerMetadataPublisher.onMetadataUpdate(BrokerMetadataPublisher.scala:173)
at org.apache.kafka.image.loader.MetadataLoader.maybePublishMetadata(MetadataLoader.java:341)
at org.apache.kafka.image.loader.MetadataBatchLoader.applyDeltaAndUpdate(MetadataBatchLoader.java:272)
at org.apache.kafka.image.loader.MetadataBatchLoader.maybeFlushBatches(MetadataBatchLoader.java:208)
at org.apache.kafka.image.loader.MetadataLoader.lambda$handleCommit$1(MetadataLoader.java:365)
at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: java.nio.file.AccessDeniedException: C:\Kafka\kafka\data\belajarkafka-0 -> C:\Kafka\kafka\data\belajarkafka-0.71e1d715323a4fb5b2910d13879a4bcf-delete
at java.base/sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:89)
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:1431)
at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:978)
... 25 more
[2025-06-28 01:57:46,095] WARN [ReplicaManager broker=1] Stopping serving replicas in dir C:\Kafka\kafka\data (kafka.server.ReplicaManager)
[2025-06-28 01:57:46,104] INFO [GroupCoordinator 1]: Removed 0 offsets associated with deleted partitions: belajarkafka-0. (kafka.coordinator.group.GroupCoordinator)
[2025-06-28 01:57:46,106] WARN [ReplicaManager broker=1] Broker 1 stopped fetcher for partitions and stopped moving logs for partitions because they are in the failed log directory C:\Kafka\kafka\data. (kafka.server.ReplicaManager)
[2025-06-28 01:57:46,106] WARN Stopping serving logs in dir C:\Kafka\kafka\data (kafka.log.LogManager)
[2025-06-28 01:57:46,110] INFO [DynamicConfigPublisher broker id=1] Updating topic belajarkafka with new configuration : (kafka.server.metadata.DynamicConfigPublisher)
[2025-06-28 01:57:46,110] ERROR Shutdown broker because all log dirs in C:\Kafka\kafka\data have failed (kafka.log.LogManager) ```


Подробнее здесь: https://stackoverflow.com/questions/796 ... -directory