Hi Debraj, such errors are usually caused by having two versions of Kafka in different places. Did you put flink-connector-kafka into lib/, plugin/, or specifically pointed yarn to it in some way?
You should only include it into your user jar. The user jar should not reside in any of the aforementioned places as well. Best, Arvid On Tue, Aug 24, 2021 at 2:02 PM Debraj Manna <subharaj.ma...@gmail.com> wrote: > Fabian > > I am running it inside yarn. > > Thanks, > > On Tue, Aug 24, 2021 at 5:27 PM Fabian Paul <fabianp...@ververica.com> > wrote: > >> Hi Debraj >> >> How do you run your application? If you run it from an IDE you can set a >> breakpoint and inspect the serializer class which is used. >> >> Best, >> Fabian > >
