Re: split avro kafka field

Posted by Tzu-Li (Gordon) Tai on Nov 17, 2020; 5:57am
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/split-avro-kafka-field-tp39486p39515.html

Hi,

1. You'd have to configure your Kafka connector source to use a
DeserializationSchema that deserializes the Kafka record byte to your
generated Avro type. You can use the shipped `AvroDeserializationSchema` for
that.

2. After your Kafka connector source, you can use a flatMap transformation
to do the splitting.

Cheers,
Gordon



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/