ConfluentRegistryAvroDeserializationSchema.forGeneric() is require reader
schema .How we can used it deseralize using writer schema.
On Fri, Sep 13, 2019 at 12:04 AM Lasse Nedergaard
wrote:
> Hi Elias
>
> Thanks for letting me know. I have found it but we also need the option to
> register Avro
Hi Elias
Thanks for letting me know. I have found it but we also need the option to
register Avro Schema’s and use the registry when we write to Kafka. So we will
create a serialisation version and when it works implement it into Flink and
create a pull request for the community.
Med venlig h
Just for a Kafka source:
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#the-deserializationschema
- There is also a version of this schema available that can lookup the
writer’s schema (schema which was used to write the record) in Confluent
Schema Regi
