dagger
dagger copied to clipboard
Add support for Avro data
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.
Stencil also soon plans to add support for AVRO schemas. So, we would also need to consider how to integrate with schema registry.