Hello, What is the recommended flink streaming approach for serialising a POJO to Avro according to a schema, and pushing the subsequent byte array into a Kafka sink? Also, is there any existing approach for prepending the schema id to the payload (following the Confluent pattern)?
Thanks, Elliot.
