We have the application that was running without any issue before enable IAM. After IAM is configured, we started getting below errors in very low frequency.
"java.lang.IllegalStateException: Correlation id for response (526263) does not match request (0), request header: RequestHeader(apiKey=SASL_HANDSHAKE, apiVersion=1, clientId=ef958fc7-4d43-490d-aa3c-c1ba0d189003-StreamThread-1-restore-consumer, correlationId=0)
Encountered the following unexpected Kafka exception during processing, this usually indicate Streams internal errors:","error":{"stack":"org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'responses': Error reading array of size 1398754643, only 5 bytes available
There are threads indicate that the mismatch of kafka server-client version would cause above errors, but why does it only happen when IAM is enabled?
Versions we use:
Kafka cluster version: 2.6.2
kafka-client version: 2.5.0
We have the application that was running without any issue before enable IAM. After IAM is configured, we started getting below errors in very low frequency.
"java.lang.IllegalStateException: Correlation id for response (526263) does not match request (0), request header: RequestHeader(apiKey=SASL_HANDSHAKE, apiVersion=1, clientId=ef958fc7-4d43-490d-aa3c-c1ba0d189003-StreamThread-1-restore-consumer, correlationId=0)
Encountered the following unexpected Kafka exception during processing, this usually indicate Streams internal errors:","error":{"stack":"org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'responses': Error reading array of size 1398754643, only 5 bytes available
There are threads indicate that the mismatch of kafka server-client version would cause above errors, but why does it only happen when IAM is enabled?
Versions we use:
Kafka cluster version: 2.6.2
kafka-client version: 2.5.0