2 a13615323102 a13615323102 于 2016.04.20 14:28 提问

在新建和删除kafka的topic时出现问题
kafka本身存在一个12个分区的topic,我重新增加一个12个分区的topic后,在Partition Information中出现Partition 0的leader为-2,点击进入后显示 broker id -2 :Yikes! Broker not found -2 for cluster kafka_manager.  
然而我的broker ID 并没有使-2的,并且在我删除该topic后(删除失败),partition information中每一个的leader都变成了负数(-1),报错跟上述相同。
    求解为什么会出现这个问题,并且该如何彻底删除kafka topic残留的全部数据(kafka本身存在删除缺陷,如何较好的解决这个缺陷)。
    菜鸟入坑,求大神帮忙解决啊!

2个回答

xiaoyu_BD
xiaoyu_BD   2016.08.25 23:26
已采纳

http://blog.csdn.net/xiaoyu_bd/article/details/52268647 这里有彻底删除topic的两种方法

a13615323102
a13615323102 按照你说的第一步第二步都做了,但kafkamanage上还是显示删掉的topic name,topic的数据删掉了,很奇怪。重现安装了Kafka和Zookeeper。(我现在已经不做这个了)
接近 2 年之前 回复
qq_24831059
qq_24831059   2016.05.26 23:37

kafka-logs删除,zk删除,topic delete;基本上差不多了

a13615323102
a13615323102 还是没有删除彻底,在kafka-manage上依旧显示topic的名称,但是这个topic确实删除的差不多了,最后选择了卸载重装= =
接近 2 年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!
其他相关推荐
kafka删除新建topic
原理翻译可参考:http://blog.csdn.net/smallnest/article/details/38491483 删除kafka的topic,参照http://blog.csdn.net/fengzheku/article/details/50585972 1、删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka
kafka删除和创建topic
kafka操作topic的方法: 1、查看topic列表:       bin/kafka-topics.sh --zookeeper node1:port,node2:port,node3:port/kafkachroot --list 2、删除topic :       1) bin/kafka-topics.sh --zookeeper node1:port
删除kafka topic后再重新建同名topic
首先确保 delete.topic.enable=true 第一步:bin/kafka-topics --zookeeper zookeeper集群 --delete --topic topicName 第二步:进入zookeeper命令行,删除三个目录①rmr /brokers/topics/market ②rmr /admin/delete_topics/market ③
kafka彻底删除topic的两种方法
本文基于kafka0.9.0.1亲测有效,转载请说明! 方法一:快速配置删除法 1.kafka启动之前,在server.properties配置delete.topic.enable=true   2.执行命令bin/kafka-topics.sh --delete --topic test --zookeeper zk:2181 或者使用kafka-manager集群管理工具删除
Kafka 删除kafka中的topic 多种方式
最近由于项目需要需要删除 kafka 中的topic : 下面记录下删除的方式: 方式一 (我的机器不成功不知道是什么原因) 原理:通过kafka 的配置: delete.topic.enable Enables delete topic. Delete topic through the admin tool will have
Kafka 彻底删除 topic 操作命令流程
如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况 1.如果当前topic没有使用过即没有传输过信息:可以彻底删除 2.如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为删除(marked for deletion) 针对第二种情况(以game_log_game_skuld_01这个top
kafka彻底删除topic
今天发现一个线上kafka(版本为0.8.2.2)多天前已不再消费的topic标记为删除(marked for deletion),而我们每天有定时删除topic的shell脚本,会把无用的topic干掉,但发现这些topic只是被标记为删除,而并没有真正删除
kafka-topics.sh的delete命令删除topic
如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况: 如果当前topic没有使用过即没有传输过信息:可以彻底删除如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为删除(marked for deletion)。 要彻底把情况2中的topic删除必须把kafka中与当前topic相关的数据目录和zookeep
Kafka删除topic
两种方法:   一、修改配置文件server.properties     添加如下配置:         delete.topic.enable=true   说明:官方给的文档说明“Enables delete topic. Delete topic through the admin tool will have no effect if this config is turne
彻底删除kafka的topic方法
1、删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录 2、Kafka 删除topic的命令是: kafka/bin/kafka-topics.sh --delete --zookeeper Zookeeper地址 --topic 主题名称 如果kafaka启动时加载的配置文件中server.p