Alex created KAFKA-6221:
---------------------------
Summary: ReplicaFetcherThread throws
UnknownTopicOrPartitionExeption on topic creation
Key: KAFKA-6221
URL: https://issues.apache.org/jira/browse/KAFKA-6221
Project: Kafka
Issue Type: Bug
Components: core
Affects Versions: 0.10.2.1, 0.10.2.0
Environment: RHEL 7
Reporter: Alex
This issue appeared to happen frequently on 0.10.2.0. On 0.10.2.1 it's a way
harder to reproduce. We'll focus on reproducing it on 0.10.2.1.
*Topology:* 3 brokers, 1 zk.
*Reproducing strategy:* create a few dozens topics (say, 40) one by one, each
with replication factor 2. Number of partitions, generally, does not matter
but, for easier reproduction, should not be very small (around 30 or so).
*CREATE 40 TOPICS:*
for i in {1..40}; do bin/kafka-topics.sh --create --topic "topic${i}_p28_r2"
--partitions 28 --replication-factor 2 --zookeeper :2165; done
{code:java}
*BROKER 1*
[2017-11-15 16:46:00,853] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,27] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:00,853] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,27] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:00,854] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,9] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:00,854] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,9] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:00,854] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,3] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:00,854] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,3] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:00,854] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,15] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:00,854] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,15] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:00,854] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,21] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:00,854] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic1_p28_r2,21] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
*BROKER 2*
[2017-11-15 16:46:36,408] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,12] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:36,408] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,12] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:36,410] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,0] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:36,410] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,0] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:36,410] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,6] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:36,410] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,6] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:36,410] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,24] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:36,410] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,24] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:36,410] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,18] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:46:36,410] ERROR [ReplicaFetcherThread-0-3], Error for partition
[topic20_p28_r2,18] to broker
3:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
*BROKER 3*
[2017-11-15 16:47:00,393] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic30_p28_r2,16] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:47:00,393] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic30_p28_r2,16] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:47:00,393] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic30_p28_r2,10] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:47:00,393] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic30_p28_r2,10] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:47:00,393] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic30_p28_r2,4] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:47:00,393] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic30_p28_r2,4] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:47:00,393] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic30_p28_r2,22] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
[2017-11-15 16:47:00,393] ERROR [ReplicaFetcherThread-0-2], Error for partition
[topic30_p28_r2,22] to broker
2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
{code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
