Kafka的新下载已经包含旧主题

问题描述:

我正在使用Kafka下载包,并遵循Kafka入门指南。因此,我创建了一个称为测试的示例主题。Kafka的新下载已经包含旧主题

然后当我想尝试使用kafka-acls.sh脚本设置一些访问控制列表。出于某种原因,我没有在我的卡包包的bin目录中找到该脚本。

所以,我从他们的网站上下载了一个新鲜的卡夫卡包来检查和这个脚本是可用的。 (我不知道为什么,或者它如何在较早的包是不存在)

然而,当我从我的新包装开始卡夫卡,并试图创造同一主题测试,我得到一个错误说这个话题已经存在。

我想弄清楚,即使是新鲜下载的实例,这是如何实现的?卡夫卡是否将某些公共目录中的主题保存了下来?

Shabir

找到原因。我认为,如果主题是跨越不同的Kafka包持续存在的,那么它必须存储在磁盘之外的某个地方,而不是包本身。

的搜索证明,在目录中动物园管理员存储其细节由指出DATADIRzookeeper.properties文件,该文件是默认的/ tmp /饲养员里面一点点。

一旦我删除这个文件夹,并开始一个新鲜的卡夫卡包,所有以前的主题都消失了,它的行为像一个新鲜包

谢谢 Shabir