1.Kafka如何开启远程访问?
#打开配置文件
vim config/server.properties
server.properties 文件截图
将advertised.listeners注释去掉,换成你远程主机的截图。
你为啥不投啊2.如何彻底删除Kafka中的topic
2.1方法一
修改kafaka配置文件server.properties, 添加
#开启允许删除主题
delete.topic.enable=true
重启kafka,之后通过kafka命令行就可以直接删除topic
通过命令行删除topic:
bin/kafka-topics.sh --delete --zookeeper {zookeeper server} --topic {topic name}
2.1方法二(没有配置delete.topic.enable=true)
1、先通过命令行删除topic:
bin/kafka-topics.sh --delete --zookeeper {zookeeper server} --topic {topic name}
因为kafka配置文件中server.properties没有配置```
delete.topic.enable=true
此时的删除并不是真正的删除,只是把topic标记为:marked for deletion
你可以通过命令:
bin/kafka-topics --zookeeper {zookeeper server} --list
来查看所有topic
2、删除kafka存储目录
kafka存储目录配置在(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")
log.dirs
在kafka-logs里面有以topic为名字的文件夹,里面有日志,将整个文件夹删除就行
3, 删除zookeeper里面的topic记录
#切换到zookeeper安装目录
bin/zkCli.sh
#找到topic所在的目录:
ls /brokers/topics
主题名
找到你要删除的主题将其删除,比如图中的主题topic-demo
执行命令:
rmr /brokers/topics/{topic name}
即可,此时topic被彻底删除。
另外被标记为marked for deletion的topic你可以在zookeeper客户端中通过命令获得:
ls /admin/delete_topics/{topic name}
如果你删除了此处的topic,那么marked for deletion 标记消失
网友评论