Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-7020

Error when deleting topic with access denied exception

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • log
    • None
    • Windows 10

    Description

      Error collected from server.log of Kakfa broker: 

      2018-06-07 15:05:17,805] ERROR Error while renaming dir for test5-1 in log dir D:\data\Kafka\kafka-logs (kafka.server.LogDirFailureChannel)
      java.nio.file.AccessDeniedException: D:\data\Kafka\kafka-logs\test5-1 -> D:\data\Kafka\kafka-logs\test5-1.87985bad40e441e1a4d08af4541db7ce-delete
      at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83)
      at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
      at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:387)
      at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287)
      at java.nio.file.Files.move(Files.java:1395)
      at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:697)
      at kafka.log.Log$$anonfun$renameDir$1.apply$mcV$sp(Log.scala:579)
      at kafka.log.Log$$anonfun$renameDir$1.apply(Log.scala:577)
      at kafka.log.Log$$anonfun$renameDir$1.apply(Log.scala:577)
      at kafka.log.Log.maybeHandleIOException(Log.scala:1678)
      at kafka.log.Log.renameDir(Log.scala:577)
      at kafka.log.LogManager.asyncDelete(LogManager.scala:813)
      at kafka.cluster.Partition$$anonfun$delete$1.apply(Partition.scala:240)

      at kafka.cluster.Partition$$anonfun$delete$1.apply(Partition.scala:235)
      at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)
      at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:258)
      at kafka.cluster.Partition.delete(Partition.scala:235)
      at kafka.server.ReplicaManager.stopReplica(ReplicaManager.scala:347)
      at kafka.server.ReplicaManager$$anonfun$stopReplicas$2.apply(ReplicaManager.scala:377)
      at kafka.server.ReplicaManager$$anonfun$stopReplicas$2.apply(ReplicaManager.scala:375)
      at scala.collection.Iterator$class.foreach(Iterator.scala:891)
      at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
      at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
      at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
      at kafka.server.ReplicaManager.stopReplicas(ReplicaManager.scala:375)
      at kafka.server.KafkaApis.handleStopReplicaRequest(KafkaApis.scala:198)
      at kafka.server.KafkaApis.handle(KafkaApis.scala:109)
      at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:69)
      at java.lang.Thread.run(Thread.java:748)
      Suppressed: java.nio.file.AccessDeniedException: D:\data\Kafka\kafka-logs\test5-1 -> D:\data\Kafka\kafka-logs\test5-1.87985bad40e441e1a4d08af4541db7ce-delete
      at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83)
      at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
      at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:301)
      at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287)
      at java.nio.file.Files.move(Files.java:1395)
      at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:694)
      ... 23 more
      [2018-06-07 15:05:17,805] ERROR Error while renaming dir for test5-1 in log dir D:\data\Kafka\kafka-logs (kafka.server.LogDirFailureChannel)
      java.nio.file.AccessDeniedException: D:\data\Kafka\kafka-logs\test5-1 -> D:\data\Kafka\kafka-logs\test5-1.87985bad40e441e1a4d08af4541db7ce-delete
      at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83)
      at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
      at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:387)
      at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287)
      at java.nio.file.Files.move(Files.java:1395)
      at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:697)
      at kafka.log.Log$$anonfun$renameDir$1.apply$mcV$sp(Log.scala:579)
      at kafka.log.Log$$anonfun$renameDir$1.apply(Log.scala:577)
      at kafka.log.Log$$anonfun$renameDir$1.apply(Log.scala:577)
      at kafka.log.Log.maybeHandleIOException(Log.scala:1678)
      at kafka.log.Log.renameDir(Log.scala:577)
      at kafka.log.LogManager.asyncDelete(LogManager.scala:813)
      at kafka.cluster.Partition$$anonfun$delete$1.apply(Partition.scala:240)
      at kafka.cluster.Partition$$anonfun$delete$1.apply(Partition.scala:235)
      at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)
      at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:258)
      at kafka.cluster.Partition.delete(Partition.scala:235)
      at kafka.server.ReplicaManager.stopReplica(ReplicaManager.scala:347)
      at kafka.server.ReplicaManager$$anonfun$stopReplicas$2.apply(ReplicaManager.scala:377)
      at kafka.server.ReplicaManager$$anonfun$stopReplicas$2.apply(ReplicaManager.scala:375)
      at scala.collection.Iterator$class.foreach(Iterator.scala:891)
      at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
      at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
      at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
      at kafka.server.ReplicaManager.stopReplicas(ReplicaManager.scala:375)
      at kafka.server.KafkaApis.handleStopReplicaRequest(KafkaApis.scala:198)
      at kafka.server.KafkaApis.handle(KafkaApis.scala:109)
      at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:69)
      at java.lang.Thread.run(Thread.java:748)
      Suppressed: java.nio.file.AccessDeniedException: D:\data\Kafka\kafka-logs\test5-1 -> D:\data\Kafka\kafka-logs\test5-1.87985bad40e441e1a4d08af4541db7ce-delete
      at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83)
      at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
      at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:301)
      at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287)
      at java.nio.file.Files.move(Files.java:1395)
      at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:694)
      ... 23 more

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              wadewu wade wu
              Votes:
              1 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated: