[jira] [Created] (KAFKA-6648) Fetcher.getTopicMetadata() only returns "healthy" partitions, not all

["radai rosenblatt (JIRA)" <ji...@apache.org>]

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


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

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
(v7.6.3#76005)