Flink 2.x and using SSINK with AVRO serializer for vale.

[Noort, Erwin van de]

Hi,

I am using Flink 2.2-SNAPSHOT. I try to read and write from and to a Kafka 
topic using a AVRO schema.


  *
I want to read from a KafkaSource<Tuple2<String, Point>> the key is a String 
and the Value is an AVRO schema that is in a schema registry.
  *
Then I want to produce the message to a Kafka Topic  using a SINK, with a 
String as a Key and a Pojo Point and a AVRO schema for the Point.

Basically read from a kafka topic and write is back to a kafla topic using a 
Apicurio Schema registry  for the AVRO Schema Registration


I am using the CDC connector librar:y

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kafka</artifactId>
    <version>4.0.1-2.0</version>
</dependency>


Question: For serializing and deserializing there is no example code available 
for Flink 2.x What is the approach to do this?