[
https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045633#comment-16045633
]
Mike Fagan commented on KAFKA-5424:
-----------------------------------
Thanks, I am seeing this running a Kafka 0.10.0.2.5 cluster with Kerberos.
Are there other details that would help debug/resolve this issue?
> 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)
