kafkatopic删除_kafka 查看topic
未分类
2023-01-16
kafkatopic删除_kafka 查看topickafkatopic删除方法一:通过kafka命令来删除方法二:使用zookeeper来删除topic要删除的topic名字为test。方法一:通过kafka命令来删除1.1通过集群管理工具如ambari设置delete.topic.enable=truedelete.topic.enable1.2通过kafka命令删除topic${KAFKA_HOME}/bin/...
kafka topic 删除
要删除的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