kafka删除topic

删除kafkatopic

首先需要执行delete后标记

./kafka-topics.sh –-zookeeper 127.0.0.1:2181 –list

./kafka-topics.sh –delete –-zookeeper ip:2181 –topic topicname

添加标签后根据server.properties文件中的log.dirs配置删除topic储存目录

进入zk客户端执行

./zkCli.sh

ls /brokers/topics/topicname

rmr /admin/delete_topics/topicname

 

注意这里有可能删除不掉，因客户端服务在持续连接该topic会导致删除不掉.

创建topic

./kafka-topics.sh –create –topic topicname –zookeeper ip:2181 –partitions 6 –replication-factor 2

修改topic中partition

./kafka-topics.sh –alter –zookeeper ip:2181 –partitions 8 –topic topicname