You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Soheil Pourbafrani <so...@gmail.com> on 2018/03/31 18:25:06 UTC

Flink Kafka producer: Object of class is not serializable

I got an error in using Flink Kafka connector for producing data. I
describe the problem here
<https://stackoverflow.com/questions/49589643/flink-kafka-producer-object-of-class-is-not-serializable?noredirect=1#comment86188259_49589643>
in
Stackoverflow. Pls help

Thanks!

Re: Flink Kafka producer: Object of class is not serializable

Posted by Chesnay Schepler <ch...@apache.org>.

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 
> <https://stackoverflow.com/questions/49589643/flink-kafka-producer-object-of-class-is-not-serializable?noredirect=1#comment86188259_49589643> in 
> Stackoverflow. Pls help
>
> Thanks!