【发布时间】:2021-05-16 09:42:53
【问题描述】:
我尝试在 Windows 上设置 kafka 和 zookeeper。 最初,我创建了主题、生产者和消费者。它工作正常。 然后我使用以下命令删除了一个主题:
kafka-run-class.bat kafka.admin.TopicCommand --delete --topic junk --zookeeper localhost:2181
现在每次我重新运行 kafka 时,它都会因以下错误而终止: java.nio.file.AccessDeniedException: C:\kafka_2.12-2.8.0\kafka_2.12-2.8.0kafka-logs\junk-0 -> C:\kafka_2.12-2.8.0\kafka_2.12-2.8 .0kafka-logs\junk-0.305f67a1260f4cccb87d9367c6619fd2-delete
我尝试删除 zookeper 和 kafka 目录并为两者使用新目录。但不知何故,它保留了以前保存的主题和日志(我不知道它们存储在什么位置)。
谁能告诉我如何解决这个问题?
【问题讨论】:
-
请出示您的代理 server.properties 文件。默认情况下,Kafka 将数据存储在 /tmp 中,这在 windows 上显然不存在。该错误还告诉您正在对哪些文件执行操作,那么这些文件是否真的存在?而且,顺便说一句,您不应该在 cli 操作上使用已弃用的 Zookeeper 标志
标签: apache-kafka apache-zookeeper