You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/01 18:30:00 UTC
[jira] [Resolved] (KAFKA-5424) KafkaConsumer.listTopics() throws
Exception when unauthorized topics exist in cluster
[ 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)