Verwenden der Azure-Schemaregistrierung in Event Hubs über Apache Kafka und andere Apps

  • Artikel

In vielen Ereignisstreaming- und Messagingszenarien enthalten die Ereignis- oder Nachrichtennutzdaten strukturierte Daten. Schemagesteuerte Formate wie Apache Avro werden häufig verwendet, um solche strukturierten Daten zu serialisieren oder zu deserialisieren.

Ein Ereignisproducer verwendet ein Schema, um die Ereignisnutzdaten zu serialisieren und sie in einem Ereignisbroker wie Event Hubs zu veröffentlichen. Ereignisconsumer lesen die Ereignisnutzdaten aus dem Broker und deserialisieren sie mit demselben Schema. Daher können sowohl Producer als auch Consumer die Integrität der Daten mit dem gleichen Schema überprüfen.

Bild, das die Serialisierung und Deserialisierung von Ereignisnutzdaten durch Produzenten und Consumer anhand von Schemas aus der Schemaregistrierung zeigt.

Was ist die Azure-Schemaregistrierung?

Die Azure-Schemaregistrierungs ist eine Funktion von Event Hubs, die ein zentrales Repository für Schemas für ereignisgesteuerte und nachrichtenzentrierte Anwendungen bereitstellt. Sie bietet Ihren Producer- und Consumeranwendungen die Flexibilität, Daten auszutauschen, ohne das Schema verwalten und gemeinsam nutzen zu müssen. Sie stellt außerdem ein einfaches Governanceframework für wiederverwendbare Schemas bereit und definiert die Beziehung zwischen Schemas über ein Gruppierungskonstrukt (Schemagruppen).

Bild, das die Serialisierung und Deserialisierung von Ereignisnutzdaten durch einen Produzenten und einen Consumer anhand eines Schemas aus der Schemaregistrierung zeigt.

Mit schemagesteuerten Serialisierungsframeworks wie Apache Avro kann das Verschieben von Serialisierungsmetadaten in freigegebene Schemas ebenfalls zur Verringerung des Mehraufwands pro Nachricht beitragen. Das liegt daran, dass nicht jede Nachricht mit Metadaten (Typinformationen und Feldnamen) versehen werden muss, wie es bei Formaten mit Tags wie JSON der Fall ist.

Hinweis

Das Feature ist im Basic-Tarif nicht verfügbar.

Durch die Speicherung von Schemas zusammen mit den Ereignissen und innerhalb der Ereignisinfrastruktur wird sichergestellt, dass die für die Serialisierung oder Deserialisierung erforderlichen Metadaten immer erreichbar sind und Schemas nicht falsch platziert werden können.

Nächste Schritte