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
此处为创建同名主题,相当于删除后重建,完成。
Tag标签:「删除 kafka」更新时间:「2021-11-05 01:10:04」阅读次数:「834」