kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Alexandru Ionescu (Jira)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-9854) Re-authenticating causes mismatched parse of response
Date Fri, 08 Jan 2021 10:30:00 GMT

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

Alexandru Ionescu commented on KAFKA-9854:
------------------------------------------

Hello,

I was not able to reproduce this. We have an OpenShift cluster with 3 instance Kafka installed
using Strimzi Operator and OAUTHBEARER / SASL_PLAINTEXT security. This issue happens randomly
for each consumer once every few hours / days. 

What is strange is that if I have 2 instance of the same application that consumes, the consumer
group appears STABLE after this error, but the consumer no longer reads certain partitions.

Any ideas on how to reproduce this or how to investigate further? 

Best regards,
Alex

> Re-authenticating causes mismatched parse of response
> -----------------------------------------------------
>
>                 Key: KAFKA-9854
>                 URL: https://issues.apache.org/jira/browse/KAFKA-9854
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Chia-Ping Tsai
>            Assignee: Chia-Ping Tsai
>            Priority: Critical
>             Fix For: 2.6.0, 2.5.1
>
>
> the schema of LIST_OFFSETS consists of
>  # throttle_time_ms:INT32 and
>  # responses:ARRAY
>  
>  If throttle_time_ms is zero and size of responses is small enough, its binary is compatible
to schema of SASL_HANDSHAKE composed of
>  # error_code:INT16 and
>  # mechanisms:ARRAY(STRING)
>  
>  Hence, there is no Schema error when SASL_HANDSHAKE tries to parse response of LIST_OFFSETS
but the check of correction id throws IllegalStateException due to mismatched error. The IllegalStateException
is NOT caught and the mismatched response is not sent back to Selector so the cascading error
happens that all following responses are parsed by incorrect Schema.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message