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