我正在使用Kafka下载包，并遵循Kafka入门指南。因此，我创建了一个名为test的示例主题。
然后，当我想尝试使用kafka-acls.sh脚本设置一些访问控制列表时。出于某种原因，我没有在我的Kafka包的bin目录中找到那个脚本。
所以，我从他们的网站下载了一个新的Kafka包来检查，这个脚本是可用的(我不知道为什么或者为什么它不在早期的包中）
然而，当我从我的新包开始kafka并试图创建相同的主题测试时，我得到一个错误，说这个主题已经存在了。
我试图弄清楚，即使是一个新下载的示例，这是怎么可能的？Kafka是否将主题保存在某个公共目录中？
寒酸的
1条答案
按热度按时间5vf7fwbs1#
找到了原因。我想，如果这些主题即使在不同的kafka包中也被持久化，那么它必须存储在磁盘中的某个地方，而不是包本身。
稍加搜索就可以证明zookeeper将其详细信息存储在zookeeper.properties文件中datadir指向的目录中，该文件默认为/tmp/zookeeper。
一旦我删除了这个文件夹，并开始一个新的Kafka包所有以前的主题都消失了，它的行为就像一个新的新包。
谢谢谢比尔