Anna Povzner created KAFKA-8480:
-----------------------------------
Summary: Clients may fetch incomplete set of topic partitions
during cluster startup
Key: KAFKA-8480
URL: https://issues.apache.org/jira/browse/KAFKA-8480
Project: Kafka
Issue Type: Bug
Affects Versions: 2.2.1
Reporter: Anna Povzner
Assignee: Anna Povzner
KafkaConsumer#partitionsFor() or AdminClient#describeTopics() may return not
all partitions for a given topic when the cluster is starting up (after cluster
was down).
The cause is controller, on becoming a controller, sending
UpdateMetadataRequest for all partitions with at least one online replica, and
then a separate UpdateMetadataRequest for all partitions with at least one
offline replica. If client sends metadata request in between broker processing
those two update metadata requests, clients will get incomplete set of
partitions.
Proposed fix: controller should send one UpdateMetadataRequest (containing all
partitions) in ReplicaStateMachine#startup().
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
