首页 > 其他 > 详细

删除kafka的topic及kafka基本命令

时间:2015-12-19 16:30:28      阅读:241      评论:0      收藏:0      [点我收藏+]

kafka的topic默认是不允许被删除的,删除后在topic后会出现”marked for deletion”字样,实际并未删除,现在创建同样的topic会提示topic已经存在。

解决办法:

server.properties配置文件中添加:delete.topic.enable=true

之后重启kafka,会发现之前被标记删除的topic已经不存在了。

kafka操作基本命令:

创建topic:

bin/kafka-topics.sh --create --zookeeper zkserver:zkport --replication-factor 1 --partitions 1 --topic topic-name

删除topic:

bin/kafka-topics.sh --delete --zookeeper zkserver:zkport topic-name

查看topic列表:

bin/kafka-topics.sh --list --zookeeper zkserver:zkport topic-name

删除kafka的topic及kafka基本命令

原文:http://www.cnblogs.com/aresxin/p/5059207.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!