ConfluentSchemaRegistrySerializer în Apache Kafka în Apache Kafka

Cum economisește spațiu Schema Registry Serializer

Dacă ai trimite o schemă completă Avro sau JSON la fiecare mesaj, payload-ul ar avea câțiva kiloocteți doar din cauza metadatelor. KafkaAvroSerializer funcționează inteligent:

1. Înregistrează schema o singură dată în Schema Registry și primește un Schema ID întreg (4 octeți).
2. Fiecare mesaj expediat pe Kafka conține la început octetul magic 0x0 urmat de cei 4 octeți ai Schema ID-ului și payload-ul binar compact.
3. La recepție, deserializatorul citește ID-ul de 4 octeți, descarcă schema o singură dată în cache-ul local și decodează datele instantaneu.

Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class.getName());
props.put("schema.registry.url", "http://localhost:8081");