Forum Discussion
Eventstream read EventHub with Avro format and Schema Registry (not schema embedded)
- 1 year ago
Hi khoa_nguyenanh , Thank you for reaching out to the Microsoft Community Forum.
As you observed, when Avro messages include the schema directly embedded in the payload, the pipeline will be read and process the data without any issues. This embedded schema approach is, as of now, the only supported method for Avro decoding in Eventstream. Microsoft has not yet announced support for resolving external schemas from Azure Schema Registry within Eventstream and there’s nothing on the public roadmap or in the documentation to suggest that this capability is coming soon. So, while it’s a reasonable expectation, it’s not something you can plan around at this stage.
If changing the producing application to embed schemas isn’t possible, there’s still a practical workaround. You can implement a lightweight middleware, typically using an Azure Function or Stream Analytics job that reads from your existing Event Hub, deserializes the Avro message using the Schema Registry, then re-serializes it with the schema embedded in the payload. That transformed message can be forwarded to another Event Hub, which Fabric Eventstream can consume.
If this helped solve the issue, please consider marking it “Accept as Solution” so others with similar queries may find it more easily. If not, please share the details, always happy to help.
Thank you.
Thanks for your confirmation.
We actually implemented Azure Function for other feature which is not required realtime data.
However, in this scenarior, it required realtime solution which can provided by Eventstream.
The embeded schema solution is an old approach. While the Schema registry is newer solution with more advantages provided by Microsoft.
Anyway, Thanks again. Let me discuss with the team for a workaround solution.
- v-hashadapu1 year ago
Community Support
Hi khoa_nguyenanh , thanks for the update. We would be glad to hear your workaround. Could you please share the details here and mark it as 'Accept as solution' so others with similar issues may find it easily? If you have any other questions, feel free to post them (as a new post) in the community. We're always happy to assist.
Thank you.