7,540
edits
Changes
→Környezet
:[[File:ClipCapIt-190327-204155.PNG]]
A Kafa produceren a Avro serializáló beküldi a sémát a séma regiszterbe, aminek visszakapja az ID-ját. Majd a séma alapján serializálja az adatokat és gyárt belőle egy Avro üzenetet, amiben benne van a séma azonosító és binárisan az üzenet, ami így nagyon kicsi helyet foglal. Ez kerül fel a megfelelő Kafka topic-ra. A Kafka consumer az üzenetben lévő séma ID alapján lekérdezi a sémát a registry-ből, majd annak segítségével deserializálja az üzenetet.
Fontos látni
==Környezet==
* kafka: 192.168.42.42:29092
* schema-registry: 192.168.42.42:8081
=Avro REST interfész=