[
https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-5424.
------------------------------
Resolution: Fixed
This has been fixed via KAFKA-3396
> 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
> Priority: Major
>
> 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
(v7.6.3#76005)
