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



我正在使用kafka下载包,并且正在遵循Kafka入门指南。因此,我创建了一个示例主题,称为 test

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

所以,我从他们的网站下载了一个新鲜的Kafka包来检查,并且此脚本可用。(我不知道为什么或如何在早期包中不存在(

但是,当我从新包装启动Kafka并尝试创建同一主题 test 时,我会遇到一个错误,说该主题已经存在。

我试图弄清楚即使有一个刚下载的实例,这是怎么可能的?Kafka是否将主题保存在某些公共目录或其他内容中?

Shabir

找到了原因。我认为,如果主题甚至在Kafka的不同捆绑包中都持续存在,则必须将其存储在捆绑包本身以外的磁盘中。

一点点搜索证明了 zookeeper 将其详细信息存储在 datadAdir 的目录中默认情况下/tmp/zookeeper

一旦我删除了此文件夹并启动了一个新鲜的kafka包,所有以前的主题都消失了,它的行为就像新的新鲜包

谢谢Shabir

最新更新