proto.lib

Tombstone và delete.retention.ms trong compacted topic

Trong compacted topic, một record có value null là tombstone đánh dấu xoá key; nó phải tồn tại đủ lâu (delete.retention.ms) để mọi consumer và mọi tiến trình rebuild state-store đọc được trước khi log compaction xoá hẳn nó, nếu không consumer offline lâu sẽ không bao giờ biết key đã bị xoá.

MessagingNâng cao2026-08-25
Tombstone và delete.retention.ms trong compacted topic

Tags

#kafka#compaction#tombstone#delete-retention#state-store#min-compaction-lag

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

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 Log Compaction

Compacted topic chỉ giữ lại giá trị mới nhất cho mỗi key, dùng tombstone để xóa, phục vụ như changelog.

#kafka#log-compaction#tombstone#changelog
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