Flink Kafka producer: Object of class is not serializable

[Soheil Pourbafrani]

I got an error in using Flink Kafka connector for producing data. I describe the problem here in Stackoverflow. Pls help

Thanks!

[Chesnay Schepler]

As answered on SO, the problem is the KeyedDeserializationSchema which is an anonymous inner class.

On 31.03.2018 20:25, Soheil Pourbafrani wrote:

I got an error in using Flink Kafka connector for producing data. I describe the problem here in Stackoverflow. Pls help

Thanks!