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)