Кафка - Исключение при топи c удаление - PullRequest
Новая
       21

Кафка - Исключение при топи c удаление

0 голосов
/ 08 июля 2020

Следующая проблема возникает при удалении топи c, и брокер отключается. Я не мог вызвать брокера даже после закрытия, он не работает с тем же исключением. Пожалуйста, предложите. 

    [2020-07-09 00:55:09,257] ERROR Error while renaming dir for topic-ack-all-0 in log dir C:\kafkalogs\kafka-logs-3 (kafka.server.LogDirFailureChannel)                    
java.nio.file.AccessDeniedException: C:\kafkalogs\kafka-logs-3\topic-ack-all-0 -> C:\kafkalogs\kafka-logs-3\topic-ack-all-0.48575004e6514c2eba6b8020a07dced5-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:834)                                                                                    
        at kafka.log.Log.$anonfun$renameDir$2(Log.scala:985)                                                                                                             
        at kafka.log.Log.renameDir(Log.scala:2337)                                                                                                                       
        at kafka.log.LogManager.asyncDelete(LogManager.scala:925)
...