radai rosenblatt created KAFKA-6648:

             Summary: Fetcher.getTopicMetadata() only returns "healthy" 
partitions, not all
                 Key: KAFKA-6648
                 URL: https://issues.apache.org/jira/browse/KAFKA-6648
             Project: Kafka
          Issue Type: Bug
          Components: clients
    Affects Versions: 1.0.1
            Reporter: radai rosenblatt
            Assignee: radai rosenblatt

if (!shouldRetry) {
   HashMap<String, List<PartitionInfo>> topicsPartitionInfos = new HashMap<>();
   for (String topic : cluster.topics())
   return topicsPartitionInfos;

this leads to inconsistent behavior upstream, for example in 
KafkaConsumer.partitionsFor(), where if there's valid metadata all partitions 
would be returned, whereas if MD doesnt exist (or has expired) a subset of 
partitions (only the healthy ones) would be returned.

This message was sent by Atlassian JIRA

Reply via email to