Продвинутый
Что такое Schema Registry в экосистеме Kafka и зачем он нужен?
Schema Registry — это отдельный сервис (обычно от Confluent), который хранит схемы данных (Avro, Protobuf, JSON Schema) для сообщений в Kafka.
Зачем нужен:
Kafka — это "глупая труба", она принимает просто массив байтов. Если Producer случайно изменит формат (например, переименует user_id в id), Consumer упадет с ошибкой парсинга.
Как работает:
1. Producer перед отправкой проверяет схему в Schema Registry.
2. Если схема валидна, отправляет бинарные данные в Kafka, прикрепив к ним только Schema ID.
3. Consumer получает байты, видит Schema ID, скачивает схему из Registry и успешно десериализует сообщение.
✅ Итог: Строгий контракт данных и защита от поломок.