Forum Discussion

khoa_nguyenanh's avatar
khoa_nguyenanh
Regular Visitor
1 year ago
Solved

Eventstream read EventHub with Avro format and Schema Registry (not schema embedded)

Hi all,   I am having an issue with the Eventstream as below scenarior. Really appriciate any help.   In the project, the application send messages to EventHub with Avro format and using Schema R...
  • v-hashadapu's avatar
    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.