Thanks Rafi .. will try it out ..
On Tue, 14 May 2019 at 1:26 PM, Rafi Aroch wrote:
> Hi Debasish,
>
> It would be a bit tedious, but in order to override the default
> AvroSerializer you could specify a TypeInformation object where needed.
> You would need to implement your own MyAvroTypeInfo i
Hi Debasish,
It would be a bit tedious, but in order to override the default
AvroSerializer you could specify a TypeInformation object where needed.
You would need to implement your own MyAvroTypeInfo instead of the provided
AvroTypeInfo.
For example:
env.addSource(kafkaConsumer)
.return
Hi Konstantin -
I did take a look at the option you mentioned. Using that option I can
register a custom serializer for a custom type. But my requirement is a bit
different - I would like to have a custom AvroSerializer for *all* types
which implement SpecificRecordBase of Avro. The reason is I wo
Hi Debasish,
this should be possible via
env.getConfig().registerTypeWithKryoSerializer(MyCustomType.class,
MyCustomSerializer.class);
You can check that the correct serializer is used with
TypeInformation.of(MyCustomType.class).createSerializer(env.getConfig());
In this case your serializer n
