[
https://issues.apache.org/jira/browse/KAFKA-9854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261184#comment-17261184
]
Alexandru Ionescu commented on KAFKA-9854:
------------------------------------------
Hello [~chia7712],
Does your PR fix issues like the one bellow?
{code:java}
2021-01-07 10:46:33.751 DEBUG 1 --- [98-202f60784965]
i.s.k.oauth.common.OAuthAuthenticator : loginWithClientSecret() -
tokenEndpointUrl:
https://sso-copo.apps.uat-ocp.bt.wan/auth/realms/copo/protocol/openid-connect/token,
clientId: client-check-adaptor, clientSecret: c9b5**ecdd, scope:
null2021-01-07 10:46:33.751 DEBUG 1 --- [98-202f60784965]
i.s.k.oauth.common.OAuthAuthenticator : loginWithClientSecret() -
tokenEndpointUrl:
https://sso-copo/auth/realms/copo/protocol/openid-connect/token, clientId:
client-check-adaptor, clientSecret: c9b5**ecdd, scope: null2021-01-07
10:46:33.788 DEBUG 1 --- [98-202f60784965] jdk.event.security
: TLSHandshake: sso-copo:443, TLSv1.2,
TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256, -10307310322021-01-07 10:49:13.920 WARN
1 --- [ntainer#0-1-C-1] o.apache.kafka.common.network.Selector : [Consumer
clientId=consumer-client-check-adaptor-v2-new-8,
groupId=client-check-adaptor-v2-new] Unexpected error from
copo-kafka-0.copo-kafka-brokers.copo.svc/10.211.2.162; closing connection
java.lang.IllegalStateException: Correlation id for response (213994) does not
match request (0), request header: RequestHeader(apiKey=SASL_HANDSHAKE,
apiVersion=1, clientId=, correlationId=0) at
org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:943) at
org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:726)
at
org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:712) at
org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveKafkaResponse(SaslClientAuthenticator.java:523)
at
org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.authenticate(SaslClientAuthenticator.java:249)
at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:177)
at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:547)
at org.apache.kafka.common.network.Selector.poll(Selector.java:485) at
org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
at
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1308)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1248)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doPoll(KafkaMessageListenerContainer.java:1107)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1063)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:988)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at
java.base/java.lang.Thread.run(Thread.java:834) 2021-01-07 10:49:13.923 ERROR 1
--- [ntainer#0-1-C-1] essageListenerContainer$ListenerConsumer : Consumer
exception java.lang.IllegalStateException: This error handler cannot process
'org.apache.kafka.common.protocol.types.SchemaException's; no record
information is available at
org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:151)
at
org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:103)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.handleConsumerException(KafkaMessageListenerContainer.java:1263)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1020)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at
java.base/java.lang.Thread.run(Thread.java:834)Caused by:
org.apache.kafka.common.protocol.types.SchemaException: Error reading field
'responses': Error reading array of size 1431586882, only 5 bytes available at
org.apache.kafka.common.protocol.types.Schema.read(Schema.java:110) at
org.apache.kafka.common.protocol.ApiKeys.parseResponse(ApiKeys.java:313) at
org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:725)
at
org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:839)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:558) at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
at
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1308)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1248)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doPoll(KafkaMessageListenerContainer.java:1107)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1063)
at
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:988)
... 3 common frames omitted
{code}
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)
