Hi Arvid,
Alexander Preuß has already replied to me and I also found a discussion on
https://stackoverflow.com/questions/51479657/flinkkafkaconsumer011-not-found-on-flink-cluster.
So by following
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/project-configuration/
This looks very odd. How do you create the fat jar? What's your Flink
version?
I don't think this is a general Flink issue or else no one would be able to
read from Kafka at all.
On Fri, Oct 15, 2021 at 4:16 AM L. C. Hsieh wrote:
> Hi, Flink developers,
>
> Does anyone encounter the following e
Hi, Flink developers,
Does anyone encounter the following error?
java.lang.NoClassDefFoundError:
org/apache/kafka/common/serialization/ByteArrayDeserializer
at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer.setDeserializer(FlinkKafkaConsumer.java:322)
at
org.apa
