KafkaSchema Registry (Confluent) là service lưu và quản lý schema của message Kafka, để producer và consumer thống nhất về format dữ liệu.
Vì sao cần: JSON không ép schema — producer đổi tên field hoặc đổi kiểu mà không báo là consumer gãy. Avro và Protobuf là format serialize nhị phân: nhỏ hơn JSON chừng 3-10 lần (giảm cả chi phí lưu trữ lẫn băng thông) và có schema evolution kèm quy tắc tương thích (BACKWARD, FORWARD, FULL).
Cách vận hành: Schema Registry lưu schema theo subject (mặc định lấy tên topic) và cấp cho mỗi schema một schema ID. Message chỉ mang theo 4 byte schema ID chứ không mang cả schema; consumer cần thì tra registry.
Quy tắc tương thích trong thực tế: thêm field mới có default value là BACKWARD compatible nên consumer cũ vẫn deserialize được. Ngược lại, xoá field hay đổi kiểu là breaking change và sẽ bị Schema Registry từ chối nếu chế độ compatibility không cho phép.
Đây là thứ gần như bắt buộc với Kafka cluster chạy production.