proto.lib

Schema Registry với Avro

Producer đăng ký schema Avro để lấy schema ID, Schema Registry kiểm tra compatibility, consumer tải lại schema để giải mã message.

MessagingTrung bình2026-07-02
Schema Registry với Avro

Tags

#schema-registry#avro#kafka#serialization

Tài liệu tham khảo

Mở rộng

Animation gốc là một file HTML tự chứa, có thể nhúng lại ở bất kỳ trang nào khác. Mở file gốc

Liên quan

MessagingTrung bình

Schema Evolution - Backward/Forward Compatibility

Schema registry áp dụng quy tắc backward và forward compatibility để cho phép producer/consumer nâng cấp schema độc lập mà không phá vỡ hệ thống đang chạy.

#schema-registry#schema-evolution#backward-compatible#forward-compatible
MessagingNâng cao

Sink stream (Kafka) xuống Lakehouse: file cột + commit metadata

Sink connector đọc liên tục từ Kafka, gom bản ghi theo cửa sổ thời gian thành file cột (Parquet), rồi commit một snapshot metadata mới cho bảng lakehouse; exactly-once đạt được bằng cách gắn việc commit offset Kafka với chính việc commit snapshot đó, không tách rời.

#kafka#sink-connector#lakehouse#table-format
MessagingNâng cao

Kafka Share Groups: hành vi hàng đợi trên log

Thay vì gán mỗi consumer một partition cố định, share group cho phép NHIỀU consumer cùng đọc một partition, ack từng record riêng lẻ — mang lại hành vi work-queue (nhiều consumer hơn partition, ack/redeliver theo record) trên cùng broker vẫn giữ log replay được, đổi lại mất thứ tự per-record.

#kafka#share-group#kip-932#queue-semantics