页面树结构

2017-11-09 ApacheCN 开源组织,第二期邀请成员活动,一起走的更远 : http://www.apachecn.org/member/209.html


MachineLearning 优酷地址 : http://i.youku.com/apachecn

转至元数据结尾
转至元数据起始

Consumers

org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. 

贡献者 : m4kE

QQ : 334552710

时间 : 2016-10-19 10:37:21

原因 : This server does not host this topic-partition. 

场景 : 

  1. storm-kafka 消费 kafka 数据。
  2. Kafka 的节点突然下线(事先没有通知)。
  3. 使用的是 BrokerHosts - ZkHosts,具体细节请看 http://www.apache.wiki/pages/viewpage.action?pageId=2884700#ApacheKafka集成-ZkHosts

解决 : 

  1. 首先查看你 Topic 的详细信息,包括分区,Leader 之类的,使用下面的命令,替换成自己的参数,确定好相关的信息。然后重启 Storm Topology 即可!~

    > bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
    Topic:my-replicated-topic	PartitionCount:1	ReplicationFactor:3	Configs:
    	Topic: my-replicated-topic	Partition: 0	Leader: 1	Replicas: 1,2,0	Isr: 1,2,0
  2. 请看 http://www.apache.wiki/pages/viewpage.action?pageId=2884700#ApacheKafka集成-ZkHosts。默认情况下 broker-partition 映射每隔60秒刷新一次从 Zookeeper,你可以将它改变为你想要的值,通过设置 host.refreshFreqSecs。(可以试一试,结果未知)。