kafka服务在清理日志时失败“未能清理日志”

lp0sw83n  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(412)

我得到下面的错误,它来在每5-7天,在清理日志目录中的日志文件后,它再次开始正常工作。是什么导致了这个问题,是的,我已经设置了日志保留2天,但为什么它会这样失败,每5天。

Failed to clean up log for __consumer_offsets-5 in dir C:\Kafka\config\Kafkakafka-logs due to IOException (kafka.server.LogDirFailureChannel)
java.nio.file.AccessDeniedException: C:\Kafka\config\Kafkakafka-logs\__consumer_offsets-5\00000000000000000000.log.cleaned
    at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83)
    at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
    at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:102)
    at sun.nio.fs.WindowsFileSystemProvider.implDelete(WindowsFileSystemProvider.java:269)
    at sun.nio.fs.AbstractFileSystemProvider.deleteIfExists(AbstractFileSystemProvider.java:108)
    at java.nio.file.Files.deleteIfExists(Files.java:1165)
    at kafka.log.Log$.deleteFileIfExists(Log.scala:2293)
    at kafka.log.LogSegment$.deleteIfExists(LogSegment.scala:684)
    at kafka.log.LogCleaner$.createNewCleanedSegment(LogCleaner.scala:433)
    at kafka.log.Cleaner.cleanSegments(LogCleaner.scala:556)
    at kafka.log.Cleaner$$anonfun$doClean$4.apply(LogCleaner.scala:528)
    at kafka.log.Cleaner$$anonfun$doClean$4.apply(LogCleaner.scala:527)
    at scala.collection.immutable.List.foreach(List.scala:392)
    at kafka.log.Cleaner.doClean(LogCleaner.scala:527)
    at kafka.log.Cleaner.clean(LogCleaner.scala:501)
    at kafka.log.LogCleaner$CleanerThread.cleanLog(LogCleaner.scala:359)
    at kafka.log.LogCleaner$CleanerThread.cleanFilthiestLog(LogCleaner.scala:328)
    at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:307)
    at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:89)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题