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/
