kafka如何删除topic

kafka | 2019-09-18 12:42:04

kafka查看topic命令

./kafka-topics.sh --list --zookeeper master:2181

 

那如何删除topic?

1.修改server.properties

delete.topic.enable=true

 

2.重启kafka

直接kill -9 kafka进程id

启动kafka

nohup ./kafka-server-start.sh ../config/server.properties &

 

3.删除topic

./kafka-topics.sh --delete --zookeeper master:2181 --topic designTopic

 

再次查看topic，有可能被删除了，就不用下面的步骤了。

但大多数情况下，只是被标记删除了designTopic - marked for deletion，还是可以使用。

下面就删除这些被标记删除的topic

 

4.打开zookeeper客户端

#./zkCli.sh

 

5.zk查看被标记删除的topic

[zk: localhost:2181(CONNECTED) 0] ls /admin/delete_topics
[designTopic, designTopc]

zk列出所有topic 

[zk: localhost:2181(CONNECTED) 1] ls /brokers/topics
[ambari_kafka_service_check, designTopic, designTopc, testTopic, test1, __consumer_offsets, testMyTopic]

 

6.zk删除topic

[zk: localhost:2181(CONNECTED) 5] rmr /brokers/topics/designTopic
[zk: localhost:2181(CONNECTED) 8] rmr /admin/delete_topics/designTopic

这下topic就彻底被删除了

 

 

登录后即可回复 登录 | 注册
    
相关文章
hive配置表transactional支持删除delete和update修改kafka集群环境配置安装搭建spring kafkatemplate 实现 kafka 发送 接受 消息 案例代码如何解决kafka 异常 no resolvable bootstrap urls given in bootstrap.serverskafka 控制台生产发送消息测试命令spark streaming 读取kafka案例代码kafka发送消息失败error when sending message to topic test1 with key nullkafka如何删除topicphp 网络 函数 删除之前设置的 http 头php 字符串 函数 删除字符串开头的空白字符（或其他字符）php mysql 函数 丢弃（删除）一个 mysql 数据库php output control 函数 得到当前缓冲区的内容并删除当前输出缓。php mongocollection 删除该集合php mongocollection 从集合中删除记录php mongodb 删除数据库php phar 删除 phar 档案中的一个文件php sam 函数 send a message to a queue or publish an item to a topicphp sam 函数 create a subscription to a specified topicphp sam 函数 cancel a subscription to a specified topickafka彻底删除topic
关注编程学问公众号