Menggunakan Azure Schema Registry di Azure Event Hubs dari Apache Kafka dan aplikasi lainnya

Dalam banyak streaming peristiwa dan skenario pesan, payload peristiwa atau pesan berisi data terstruktur. Format berbasis skema seperti Apache Avro sering digunakan untuk membuat serial atau mendeserialisasikan data terstruktur tersebut.

Produser acara menggunakan skema untuk membuat serial payload acara dan mempublikasikannya ke broker acara seperti Azure Event Hubs. Konsumen peristiwa membaca payload peristiwa dari broker dan mendeserialisasinya menggunakan skema yang sama. Jadi, baik produsen maupun konsumen dapat memvalidasi integritas data dengan dokumen skema.

Gambar yang menunjukkan produsen dan konsumen menserialisasikan dan mendeserialisasi payload peristiwa menggunakan skema dari Schema Registry.

Apa itu Azure Schema Registry?

Azure Schema Registry adalah fitur Azure Event Hubs, yang menyediakan repositori pusat untuk skema pada aplikasi yang digerakkan oleh peristiwa dan pesan-sentris. Hal ini memberikan fleksibilitas bagi aplikasi produsen dan konsumen Anda untuk bertukar data tanpa harus mengelola dan berbagi skema. Schema Registry juga menyediakan kerangka kerja tata kelola sederhana untuk skema yang dapat digunakan kembali dan mendefinisikan hubungan antara skema melalui konstruksi pengelompokan (kelompok skema).

Gambar yang menunjukkan produsen dan konsumen yang membuat serialisasi dan deserialisasi payload peristiwa menggunakan skema dari Schema Registry.

Dengan kerangka kerja serialisasi berbasis skema seperti Apache Avro, memindahkan metadata serialisasi ke dalam skema bersama juga dapat membantu mengurangi overhead per pesan. Ini karena setiap pesan tidak perlu memiliki metadata (ketik informasi dan nama bidang) seperti halnya dengan format yang ditandai seperti JSON.

Catatan

Fitur ini tidak tersedia di tingkat dasar.

Memiliki skema yang disimpan bersama peristiwa dan di dalam infrastruktur peristiwa memastikan bahwa metadata yang diperlukan untuk serialisasi atau deserialisasi selalu dalam jangkauan dan skema tidak dapat salah ditempatkan.

Langkah berikutnya