You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/12/21 18:40:00 UTC

[jira] [Commented] (KAFKA-7764) Authentication exceptions during consumer metadata updates may not get propagated

    [ https://issues.apache.org/jira/browse/KAFKA-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726966#comment-16726966 ] 

Dhruvil Shah commented on KAFKA-7764:
-------------------------------------

I had been looking into this codepath for [https://github.com/apache/kafka/pull/5542]. I can take a stab at fixing this issue as well.

> Authentication exceptions during consumer metadata updates may not get propagated
> ---------------------------------------------------------------------------------
>
>                 Key: KAFKA-7764
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7764
>             Project: Kafka
>          Issue Type: Bug
>          Components: consumer
>            Reporter: Jason Gustafson
>            Assignee: Dhruvil Shah
>            Priority: Major
>
> The consumer should propagate authentication errors to the user. We handle the common case in ConsumerNetworkClient when the exception occurs in response to an explicitly provided request. However, we are missing the logic to propagate exceptions during metadata updates, which are handled internally by NetworkClient. This logic exists in ConsumerNetworkClient.awaitMetadataUpdate, but metadata updates can occur outside of this path. Probably we just need to move that logic into ConsumerNetworkClient.poll() so that errors are always checked.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)