返回到文章

采纳

编辑于

创建topic时报错: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.

kafka

1、kafka版本kafka_2.11-0.10.1.1
2、kafka共三个节点,其中broker1和broker2均报错,broker3未报错
3、broker1报错如下:

[2017-01-06 14:08:32,579] ERROR [ReplicaFetcherThread-0-1], Error for partition [xdfjc1,4] to broker 1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-01-06 14:08:32,579] ERROR [ReplicaFetcherThread-0-1], Error for partition [xdfjc1,1] to broker 1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)

4、broker2报错如下:

[2017-01-06 14:08:33,579] ERROR [ReplicaFetcherThread-0-2], Error for partition [xdfjc1,2] to broker 2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)

5、创建的topic为3副本5个分区
6、经尝试验证:副本*分区数<12时不会报错
7、希望大牛指点一二