Usare Registro schemi di Azure in Hub eventi da Apache Kafka e altre app

In molti scenari di streaming e messaggistica di eventi, il payload dell'evento o del messaggio contiene dati strutturati. I formati basati sullo schema, ad esempio Apache Avro , vengono spesso usati per serializzare o deserializzare tali dati strutturati.

Un produttore di eventi usa uno schema per serializzare il payload degli eventi e pubblicarlo in un broker eventi, ad esempio Hub eventi. I consumer di eventi leggeno il payload degli eventi dal broker e lo deserializzano usando lo stesso schema. Pertanto, sia i produttori che i consumer possono convalidare l'integrità dei dati con lo stesso schema.

Immagine che mostra i produttori e i consumer serializzando e deserializzando il payload degli eventi usando schemi dal Registro schemi.

Che cos'è Registro schemi di Azure?

Registro schemi di Azure è una funzionalità di Hub eventi, che fornisce un repository centrale per gli schemi per le applicazioni basate su eventi e incentrate sulla messaggistica. Offre la flessibilità per i produttori e le applicazioni consumer per scambiare dati senza dover gestire e condividere lo schema. Fornisce anche un semplice framework di governance per schemi riutilizzabili e definisce la relazione tra schemi tramite un costrutto di raggruppamento (gruppi di schemi).

Immagine che mostra un produttore e un consumer serializzare e deserializzare il payload degli eventi usando uno schema dal Registro schemi.

Con i framework di serializzazione basati sullo schema, ad esempio Apache Avro, lo spostamento dei metadati di serializzazione in schemi condivisi può anche aiutare a ridurre il sovraccarico per messaggio. È perché ogni messaggio non deve avere i metadati (informazioni di tipo e nomi di campo) perché è il caso di formati contrassegnati come JSON.

Nota

La funzionalità non è disponibile nel livello di base .

La presenza di schemi archiviati insieme agli eventi e all'interno dell'infrastruttura di eventi garantisce che i metadati necessari per la serializzazione o la deserializzazione siano sempre in copertura e gli schemi non possano essere ignorati.

Passaggi successivi