Currently, Dagger only supports SerDe for Protobuf encoded messages.
- Avro SerDe is already supported in Flink. Add support for enabling it.
- Apart from SerDe, postprocessors, preprocessors, some functions like ElementAt, HashTransformer also rely on Dynamic Message APIs. Need to ensure they work for Avro data as well.
Currently, Dagger only supports SerDe for Protobuf encoded messages.