Support schema registry serializers for the reader
Closed this issue · 1 comments
crazyzhou commented
Problem description
The schema registry offers a way to get the serialization format of the data in the stream. Flink connector can take advantage of it. Note this is a part of #362 , we plan to do it step by step.
Problem location
FlinkPravegaReader
and FlinkPravegaInputFormat
Suggestions for an improvement