分类: Cache
Kafka0.8.2.1删除主题并重建操作步骤

在启动kafka时候确保删除在server.properties中有delete.topic.enable的配置,

delete.topic.enable=true

执行删除主题命令:

/usr/local/app/msg_server/kafka/0.8.2.1/bin/kafka-topics.sh --delete --zookeeper k1:2181,k2:2181,k3:2181 --topic parking_enter

此时只是打上了删除标记,不会真正删除,用list显示会看到主题后面带上了 - marked for deletion

登陆zookeeper控制台并删除brokers、admin、config节点的对应内容:

/usr/local/app/msg_server/zookeeper/3.4.6/bin/zkCli.sh
rmr /brokers/topics/parking.enter
rmr /admin/delete_topics/parking.enter
rmr /config/delete_topics/parking.enter

关闭三台机器上的kafka进程,查看对应的数据文件,并删除,否则在创建同名主题的时候回自动打上marked for deletion标签

[kafka@wgq_idc_cache_3_41 data]$ ll /usr/local/app/msg_server/kafka/0.8.2.1/data  | grep parking_enter
drwxr-xr-x 2 kafka kafka  4096 10月 30 15:05 parking_enter-0
drwxr-xr-x 2 kafka kafka  4096 10月 30 19:27 parking_enter-1
drwxr-xr-x 2 kafka kafka  4096 10月 30 15:07 parking_enter-2
drwxr-xr-x 2 kafka kafka  4096 10月 30 10:51 parking_enter-3
drwxr-xr-x 2 kafka kafka  4096 10月 30 11:53 parking_enter-4
drwxr-xr-x 2 kafka kafka  4096 10月 30 16:25 parking_enter-5
drwxr-xr-x 2 kafka kafka  4096 10月 30 11:40 parking_enter-6
drwxr-xr-x 2 kafka kafka  4096 10月 30 13:17 parking_enter-7
drwxr-xr-x 2 kafka kafka  4096 10月 30 10:12 parking_enter-8
drwxr-xr-x 2 kafka kafka  4096 10月 30 10:51 parking_enter-9
rm /usr/local/app/msg_server/kafka/0.8.2.1/data/parking_enter-* -rf   #删除parking_enter开头的主题

三台都删除完以后,重新启动kafka和zookeeper进程,三台都启动ok以后,使用list查看主题:

/usr/local/app/msg_server/kafka/0.8.2.1/bin/kafka-topics.sh --list --zookeeper k1:2181,k2:2181,k3:2181

使用create创建主题

/usr/local/app/msg_server/kafka/0.8.2.1/bin/kafka-topics.sh --create --zookeeper k1:2181,k2:2181,k3:2181 --replication-factor 2 --partitions 10 --topic parking_enter

此处为创建同名主题,相当于删除后重建,完成。


相关博文:

发表新评论