[jira] [Created] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster

["Mike Fagan (JIRA)" <ji...@apache.org>]

Mike Fagan created KAFKA-5424:
---------------------------------

             Summary: KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster
                 Key: KAFKA-5424
                 URL: https://issues.apache.org/jira/browse/KAFKA-5424
             Project: Kafka
          Issue Type: Bug
          Components: consumer
            Reporter: Mike Fagan


KafkaConsumer.listTopics() internally calls Fetcher. getAllTopicMetadata(timeout) and this method will throw a TopicAuthorizationException when there exists an unauthorized topic in the cluster. 

This behavior runs counter to the API docs and makes listTopics() unusable except in the case of the consumer is authorized for every single topic in the cluster. 

A potentially better approach is to have Fetcher implement a new method getAuthorizedTopicMetadata(timeout)  and have KafkaConsumer call this method instead of getAllTopicMetadata(timeout) from within KafkaConsumer.listTopics()





--
This message was sent by Atlassian JIRA
(v6.3.15#6346)