Sistemul Kafka Windows se va bloca după ce a funcționat o perioadă de timp

Următoarele soluții nu rezolvă complet problema și nu sunt recomandate

Windows Kafka ERROR Nu a reușit să curețe jurnalul pentru __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

[2021-07-06 09:06:10,800] EROARE: Eșecul de a curăța jurnalul pentru __consumer_offsets-42 în dir: C:\tmp\kafka-logs din cauza IOException (kafka.server.LogDirFailureChannel)
java.nio.file.FileSystemException: C:\tmp\kafka-logs\__consumer_offsets-42\00000000000000000000.timeindex.cleaned ->
C:\tmp\kafka-logs\__consumer_offsets-42\00000000000000000000.timeindex.swap: 另一个程序正在使用此文件，进程无法访问。

        la sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:86)
        la sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
        la sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:387)
        la sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287)
        la java.nio.file.Files.move(Files.java:1395)
        la org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:904)
        la kafka.log.AbstractIndex.renameTo(AbstractIndex.scala:210)
        la kafka.log.LazyIndex$IndexValue.renameTo(LazyIndex.scala:155)
        la kafka.log.LazyIndex.$anonfun$renameTo$1(LazyIndex.scala:79)
        la kafka.log.LazyIndex.renameTo(LazyIndex.scala:79)
        la kafka.log.LogSegment.changeFileSuffixes(LogSegment.scala:496)
        la kafka.log.Log.$anonfun$replaceSegments$4(Log.scala:2402)
        la kafka.log.Log.$anonfun$replaceSegments$4$adapted(Log.scala:2402)
        la scala.collection.immutable.List.foreach(List.scala:333)
        la kafka.log.Log.replaceSegments(Log.scala:2402)
        la kafka.log.Cleaner.cleanSegments(LogCleaner.scala:613)
        la kafka.log.Cleaner.$anonfun$doClean$6(LogCleaner.scala:538)
        la kafka.log.Cleaner.$anonfun$doClean$6$adapted(LogCleaner.scala:537)
        la scala.collection.immutable.List.foreach(List.scala:333)
        la kafka.log.Cleaner.doClean(LogCleaner.scala:537)
        la kafka.log.Cleaner.clean(LogCleaner.scala:511)
        la kafka.log.LogCleaner$CleanerThread.cleanLog(LogCleaner.scala:380)
        la kafka.log.LogCleaner$CleanerThread.cleanFilthiestLog(LogCleaner.scala:352)
        la kafka.log.LogCleaner$CleanerThread.tryCleanFilthiestLog(LogCleaner.scala:332)
        la kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:321)
        la kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)
        Suprimat: java.nio.file.FileSystemException: C:\tmp\kafka-logs\__consumer_offsets-42\000000000000000000000000.timeindex.cleaned -> C:\tmp\kafka-logs\__consumer_offsets-42\ 00000000000000000000000000.timeindex.swap: Un alt program folosește acest fișier și procesul este inaccesibil.

                la sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:86)
                la sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
                la sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:301)
                la sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287)
                la java.nio.file.Files.move(Files.java:1395)
                la org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:901)
                ... Încă 20