KafkaStorageException при создании новой темы в Windows

Question

Я получаю эту ошибку после того, как создал новую тему в kafka. Раньше все работало нормально:

  Caused by: java.io.IOException: The requested operation cannot be performed on a file with a user-mapped section open
    org.apache.kafka.common.errors.KafkaStorageException: Error while creating log for TEST-0 in dir C:\Tools\kafka_2.12-2.2.1\kafka-logs
    Caused by: java.io.IOException: The requested operation cannot be performed on a file with a user-mapped section open
            at java.io.RandomAccessFile.setLength(Native Method)
            at kafka.log.AbstractIndex.$anonfun$resize$1(AbstractIndex.scala:187)
            at scala.runtime.java8.JFunction0$mcZ$sp.apply(JFunction0$mcZ$sp.java:23)
            at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251)
            at kafka.log.AbstractIndex.resize(AbstractIndex.scala:173)
            at kafka.log.AbstractIndex.$anonfun$trimToValidSize$1(AbstractIndex.scala:239)
            at scala.runtime.java8.JFunction0$mcZ$sp.apply(JFunction0$mcZ$sp.java:23)
            at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251)
            at kafka.log.AbstractIndex.trimToValidSize(AbstractIndex.scala:239)
            at kafka.log.LogSegment.recover(LogSegment.scala:378)
            at kafka.log.Log.recoverSegment(Log.scala:500)
            at kafka.log.Log.recoverLog(Log.scala:606)
            at kafka.log.Log.$anonfun$loadSegments$3(Log.scala:575)
            at scala.runtime.java8.JFunction0$mcJ$sp.apply(JFunction0$mcJ$sp.java:23)
            at kafka.log.Log.retryOnOffsetOverflow(Log.scala:2060)
            at kafka.log.Log.loadSegments(Log.scala:575)
            at kafka.log.Log.<init>(Log.scala:292)
            at kafka.log.Log$.apply(Log.scala:2194)
            at kafka.log.LogManager.$anonfun$getOrCreateLog$1(LogManager.scala:716)
            at scala.Option.getOrElse(Option.scala:138)
            at kafka.log.LogManager.getOrCreateLog(LogManager.scala:674)
            at kafka.cluster.Partition.$anonfun$getOrCreateReplica$1(Partition.scala:202)
            at kafka.utils.Pool$$anon$1.apply(Pool.scala:61)
            at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
            at kafka.utils.Pool.getAndMaybePut(Pool.scala:60)
            at kafka.cluster.Partition.getOrCreateReplica(Partition.scala:198)
            at kafka.server.ReplicaManager.$anonfun$makeFollowers$4(ReplicaManager.scala:1287)
            at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149)
            at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237)
            at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230)
            at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44)
            at scala.collection.mutable.HashMap.foreach(HashMap.scala:149)
            at kafka.server.ReplicaManager.makeFollowers(ReplicaManager.scala:1264)
            at kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:1102)
            at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:195)
            at kafka.server.KafkaApis.handle(KafkaApis.scala:112)
            at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:69)
            at java.lang.Thread.run(Thread.java:748)