kafkatopic删除_kafka 查看topic

kafkatopic删除_kafka 查看topickafkatopic删除方法一:通过kafka命令来删除方法二:使用zookeeper来删除topic要删除的topic名字为test。方法一:通过kafka命令来删除1.1通过集群管理工具如ambari设置delete.topic.enable=truedelete.topic.enable1.2通过kafka命令删除topic${KAFKA_HOME}/bin/...

要删除的topic 名字为 test。

方法一:通过kafka 命令来删除

1.1 通过集群管理工具如ambari设置delete.topic.enable=true

delete.topic.enable
只听到从架构师办公室传来架构君的声音:
男儿事长征,少小幽燕客。有谁来对上联或下联?

1.2 通过kafka命令 删除topic

此代码由Java架构师必看网-架构君整理
${KAFKA_HOME}/bin/kafka-topics.sh --delete --zookeeper hostname:2181 --topic test

执行完后,topic会被标记为删除状态,随后被删除。但是如果topic正在被使用,则topic不会被删除,这种情况下需要使用zookeeper来删除,见步骤二。

方法二:使用zookeeper来删除topic

2.1
通过集群管理工具如ambari 暂时关闭kafka。
2.2
通过zookeeper 来删除topic信息。

使用zkCli.sh 连接zookeeper

${zookeeper_home}/bin/zkCli.sh 

删除topic

此代码由Java架构师必看网-架构君整理
# 查看topic信息 get /brokers/topics/test # 删除topic信息 rmr /brokers/topics/test rmr /admin/delete_topics/test

删除topic数据。
删除 kafka-logs 目录下要删除的test topic 的历史数据。

rm -rf ./test*

2.3 重启 kafka

本文来源cangchen@csdn,由架构君转载发布,观点不代表Java架构师必看的立场,转载请标明来源出处:https://javajgs.com/archives/166383
0
 

发表评论