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)
