Hi Qingsheng,
Thank you.
I am running Flink in EMR 6.3.0 which uses Flink version 1.12.1. We AWS
MSK Kafka, and we are currently using Kafka 2.2.1.
The stack trace seems empty, it only states this error:
org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to
write a non-defau
Hi Marco,
Sorry I forgot to cc the user mailing list just now.
From the exception message it looks like a versioning issue. Could you provide
some additional information, such as Flink & Kafka connector version, Kafka
broker version, and full exception stack? Also it will be helpful to paste pa
