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

["Mickael Maison (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Mickael Maison reassigned KAFKA-5424:
-------------------------------------

    Assignee: Mickael Maison

> 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
>            Assignee: Mickael Maison
>
> 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.4.14#64029)