The most common cause of such issues is usually class loading.
You probably have added the flink-connector-kafka also to flink-dist/libs.
But the connector is only meant to be bundled with your job jar afaik.
Right now, you have the Kafka classes loaded in the user code classloader
and in the syst
Hi community, I'm testing out 1.12-SNAPSHOT in master branch
I built my application with library 'flink-connector-kafka' but when I
start the app, I get
Caused by: org.apache.kafka.common.KafkaException: class
org.apache.kafka.common.serialization.ByteArrayDeserializer is not an
instance of org.a
