已删除的Kafka主题不能用相同的名称重新创建

tf7tbtn2  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(488)

我标记了一个要删除的主题,它一直放在那里不删除(即使delete.topic.enable设置为true)。因此,我按照指示,炮击其中一个Zookeeper,并运行以下命令将其删除:

rmr /brokers/topics/topicname
rmr /admin/delete_topics/topicname

然后,该主题似乎被删除(不会在list命令中返回)。但是,当我尝试用新配置(压缩已打开)重新创建它时,同步副本是空的,我无法使用该主题。即使list命令显示主题存在,消费返回时仍会出现“unknown\u topic\u or\u partition”错误。
有没有一个日志,我可以看看,为什么它不能得到正确的主题设置后删除和娱乐?我是否遗漏了一个步骤并且没有正确地删除主题?为什么重新创建的主题没有正确初始化?
在运行上述两个命令之前,我最初运行的删除主题的操作(这使主题在“marked for deletion”中保留了很长一段时间):

./kafka-topics.sh  --zookeeper $KAFKAZKHOSTS --delete --topic topicname

我跑去重现这个主题:

/usr/hdp/current/kafka-broker/bin/kafka-topics.sh --create --zookeeper $KAFKAZKHOSTS --replication-factor 3 --partitions 3 --topic topicname --config cleanup.policy=compact

Kafka版本:1.1.0.2.6.5.3005-27

uttx8gqw

uttx8gqw1#

所以我在某个地方读到,你应该重新启动经纪人,这可能会解决它。因此,我尝试了这一点,并且确信在重启后,isr处于正确的状态,主题再次可用。
我仍然想知道在什么情况下会发生这种情况,以及是否有办法在不重新启动代理的情况下修复它,因为在生产环境中,我希望避免这样做。

相关问题