无法在 Windows 中删除 Kafka 主题答案

【问题标题】：Cannot delete a Kafka topic in Windows无法在 Windows 中删除 Kafka 主题
【发布时间】：2018-07-02 15:28:04
【问题描述】：

我已将“delete.topic.enable”的 Zookeeper 属性设置为 true。但我仍然无法删除该主题。当我做 mvn install 或 mvn test 时，我遇到了以下问题：

WARN Error processing kafka.log:type=LogManager,name=LogDirectoryOffline,logDirectory=C:\Users\extznq\AppData\Local\Temp\EH4Test7267133751803693562 (com.yammer.metrics.reporting.JmxReporter:397)
javax.management.MalformedObjectNameException: Invalid character ':' in value part of property

ERROR Error while deleting healthchecktopic1516638375589-0 in dir C:\Users\extznq\AppData\Local\Temp\EH4Test9083449671042580730. (kafka.server.LogDirFailureChannel:107)
        java.io.IOException: Failed to rename log directory from C:\Users\{My-topic-path} to C:\Users\{My-topic-path}-0.0a40ae7410c2401aba0816891789c334-delete
            at kafka.log.LogManager.asyncDelete(LogManager.scala:671)
            at kafka.cluster.Partition$$anonfun$delete$1.apply(Partition.scala:178)
            at kafka.cluster.Partition$$anonfun$delete$1.apply(Partition.scala:173)
            at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:217)
            at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:225)
            at kafka.cluster.Partition.delete(Partition.scala:173)
            at kafka.server.ReplicaManager.stopReplica(ReplicaManager.scala:341)
            at kafka.server.ReplicaManager$$anonfun$stopReplicas$2.apply(ReplicaManager.scala:373)
            at kafka.server.ReplicaManager$$anonfun$stopReplicas$2.apply(ReplicaManager.scala:371)
            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:371)
            at kafka.server.KafkaApis.handleStopReplicaRequest(KafkaApis.scala:190)
            at kafka.server.KafkaApis.handle(KafkaApis.scala:104)
            at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:65)
            at java.lang.Thread.run(Thread.java:745)

ERROR [Broker id=0] Ignoring stop replica (delete=true) for partition healthchecktopic1516728986980-0 due to storage exception (state.change.logger:107)
org.apache.kafka.common.errors.KafkaStorageException: Error while deleting healthchecktopic1516728986980-0 in dir C:\Users\AppData\Local\Temp\EH4Test7267133751803693562.
Caused by: java.io.IOException: Failed to rename log directory from C:\Users\AppData\Local\Temp\EH4Test7267133751803693562\healthchecktopic1516728986980-0 to C:\Users\AppData\Local\Temp\EH4Test7267133751803693562\healthchecktopic1516728986980-0.65fc6c32c44940e58c1a45bd2972523a-delete
    at kafka.log.LogManager.asyncDelete(LogManager.scala:671)

我认为警告没问题。但是我不知道为什么会出错，尽管我以管理员身份运行 Eclipse。特别是 KafkaStorageException，我的电脑里还有 50GB。

环境：

Windows 10
动物园管理员 3.5.3-beta
卡夫卡 1.0.0

【问题讨论】：

标签： windows apache-kafka apache-zookeeper

【解决方案1】：

您的属性中似乎有一个无效字符：属性值部分中的无效字符 ':';同样在下面的行中，您使用的占位符似乎没有被正确替换：C:\Users\{My-topic-path}

此外，还有一个与文件操作相关的未解决问题，例如在 windows 环境中移动/删除，我从 0.10.2.1 升级到 1.1.0 时遇到了同样的问题

这是问题的链接：KAFKA-1194

【讨论】：