kafkaflow
kafkaflow copied to clipboard
[Feature Request]: Add AvroConvert schema registry serializer
Is your request related to a problem you have?
AvroConvert is a mechanism for producing Avro messages without needing to generate a schema and corresponding code. Reflection is used to generate a schema on the fly and publish messages directly. It follows the code-first approach for generating a schema definition, similar to Entity Framework.
Describe the solution you'd like
Ideally we have create a new nuget package called KafkaFlow.Serializer.SchemaRegistry.AvroConvert, although I'm open to suggestions. This would handle the on-the-fly serializing of Avro messages, and handle schema generating and interaction with the schema registry.
I've already put together a working POC, and am willing to refine it and submit a PR.
Are you able to help bring it to life and contribute with a Pull Request?
Yes
Additional context
No response