This issues sounds strikingly similar to FLINK-6965.
TL;DR: You must place classes loaded during serialization by the kafka
connector under /lib.
On 29.11.2017 16:15, Timo Walther wrote:
Hi Bart,
usually, this error means that your Maven project configuration is not
correct. Is your custom
Hi Bart,
usually, this error means that your Maven project configuration is not
correct. Is your custom class included in the jar file that you submit
to the cluster?
It might make sense to share your pom.xml with us.
Regards,
Timo
Am 11/29/17 um 2:44 PM schrieb Bart Kastermans:
I have
I have a custom serializer for writing/reading from kafka. I am setting
this up in main with code as follows:
val kafkaConsumerProps = new Properties()
kafkaConsumerProps.setProperty("bootstrap.servers", kafka_bootstrap)
