2 u014036123 u014036123 于 2016.01.28 19:58 提问

kafka创建的topic为none

大家好:
我创建了一个topic,查看topic的描述,情况如下:
Topic:deng3 PartitionCount:2 ReplicationFactor:2 Configs:
Topic: deng3 Partition: 0 Leader: none Replicas: 3,4 Isr:
Topic: deng3 Partition: 1 Leader: none Replicas: 4,5 Isr:
有没有人知道原因吗?

1个回答

xiaoyu_BD
xiaoyu_BD   2016.08.25 23:31

zookeeper启动了吗

Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!
其他相关推荐
topic的leader显示为none的解决办法
受此博文启发: http://blog.selfup.cn/1698.html 以单副本,3分区示例: kafka在zk中存放路径为 / (路径自行验证) 1、查看kafka的topic详细信息 2、查看zk节点 指定节点内部为空。 查看其它同级节点发现有分区信息: 3、创建分区信息 进入zookeeper-client: 首先查看节点/controller_epo...
如何在Kafka中对Topic的leader进行均衡
参考 操作背景 在创建一个topic时,kafka尽量将partition均分在所有的brokers上,并且将replicas也j均分在不同的broker上。 每个partitiion的所有replicas叫做"assigned replicas","assigned replicas"中的第一个replicas叫"preferred replica",刚创建的topic一般"p
kafka 创建topic,查看topic
创建 创建kafka topic bin/kafka-topics.sh --create --topic topicname --replication-factor 1 --partitions 1 --zookeeper localhost:2181   方法一: 执行linux命令: bin/kafka-topics.sh --create --topic topicna
kafka如何创建topic
Kafka创建topic命令很简单,一条命令足矣:bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test       这条命令会创建一个名为test的topic,有3个分区,每个分区需分配3个副本。那么在这条命令之后Kafka又做了什么
Kafka解析之topic创建(1)
在使用kafka发送消息和消费消息之前,必须先要创建topic,在kafka中创建topic的方式有以下2种: 如果kafka broker中的config/server.properties配置文件中配置了auto.create.topics.enable参数为true(默认值就是true),那么当生产者向一个尚未创建的topic发送消息时,会自动创建一个num.partitions(默认值...
apache Kafka中partition的leader为-1情况分析
1.broker shutdown的时候,partition的leader在此broker上,controller选主没有成功,移除此broker后,对应的partition的leader就被赋值成-1了。 2.给此broker发送stopReplicaRequest 调用controller.removeReplicaFromIsr,从zk读取当前partition的状态,从isr中移除此b
kafka学习七:kafka 运维
Kafka管理工具 Kafka集群管理工具 Kafka集群管理内容包括服务器启停、leader均衡、复制、集群镜像、集群扩展等。 添加服务器 向Kafka集群中添加服务器时,需要分配一个唯一的broker ID给新服务器。这时添加新服务器不会自动分配数据分区。重分配工具kafka-reassign-partitions.sh用于在broker之间移动partition。Kafka将新服务器
删除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 ③
使用Java API进行kafka topic开发
package org.sunny.two; import kafka.admin.AdminClient; import kafka.admin.AdminUtils; import kafka.admin.TopicCommand; import kafka.server.ConfigType; import kafka.utils.ZkUtils; import org.apache.k...
解决kafka集群由于默认的__consumer_offsets这个topic的默认的副本数为1而存在的单点故障问题
解决kafka集群由于默认的__consumer_offsets这个topic的默认的副本数为1而存在的单点故障问题抛出问题:__consumer_offsets这个topic是由kafka自动创建的,默认50个,但是都存在一台kafka服务器上,这是不是就存在很明显的单点故障? 经测试,如果将存储consumer_offsets的这台机器kill掉,所有的消费者都停止消费了。请问这个问题是怎么解...