Zookeeper的主题删除

问题描述 投票:0回答:1

我已使用以下命令直接从Zookeeper删除了主题,之前没有从Kafka执行删除:

zookeeper-shell.sh localhost:2181 rmr /brokers/topics/<topic_name>

现在我看到的是,该主题出现在集群中至少一个代理的log.dirs中。有没有一种可以删除的方法。

[当我现在尝试从kafka删除时,会引发以下错误

Error while executing topic command : Topic <topic_name> does not exist on ZK path <zookeeper_server_list:2181>
apache-kafka apache-zookeeper kafka-topic
1个回答
0
投票

我认为您错过了几个步骤。为了手动删除主题,您需要执行以下步骤:

1)停止Kafka服务器

2)在每个代理上,您必须删除logs.dirs下的所有主题的日志文件:

rm -rf path/to/logs/topic_name/

3)从Zookeeper中删除主题目录:

> zookeeper-shell.sh localhost:2181
> ls /brokers/topics
> rmr /brokers/topics/topic_name

4)重新启动Kafka服务器


注意,删除主题的建议方法是

/bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic topic_name

假设delete.topic.enable=true

© www.soinside.com 2019 - 2024. All rights reserved.