- 安装kafka的目录层级不要太深,目录名不要太长,否则可能在启动zk或者kafka会报命令行太长,命令语法不正确。
- 安装版本最好是kafka_x.xx-3.0.0 以下,不包含3.0,否则可能启动会报文件权限访问异常的错误,应该是bug。
- 在执行删除topic时候,只是标记删除,并不是真正删除。
本人针对删除topic,仅记录踩坑之路。
本人kafka版本kafka_2.12-2.3.1,启动zk用的是kafka自带的zk,切换到kafka安装目录下:
启动zk:
binwindowszookeeper-server-start.bat configzookeeper.properties
启动kafka:
binwindowskafka-server-start.bat configserver.properties
切换到binwoindows下查看topic列表:
kafka-topics.bat --list --zookeeper localhost:2181
新增topic:
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
新增成功如图:
然后删除该topic:(本人在kafka的配置文件server.properties中不管是否添加delete.topic.enable=true,结果都是显示标记删除,而不是真正删除)
真正删除它,可以如下 *** 作:
开启zk客户端:(本人因为是启动kafka自带的zk,所以zk客户端脚本命令如下图)
- 找到topic所在的目录:ls /brokers/topics
- 找到要删除的topic,执行命令:rmr /brokers/topics/【topic name】即可,此时topic被彻底删除。
- 另外被标记为marked for deletion的topic你可以在zookeeper客户端中通过命令获得:ls /admin/delete_topics
如图:
再次查看topic列表,就删除掉了。
最后顺便把多余的关于该topic的kafka的日志文件删掉就ok了。
仅供参考,每个人实际情况不一样。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)