proto.lib

Replay Message Từ Một Thời Điểm Trong Quá Khứ

Consumer có thể tua lại (rewind/replay) việc đọc message bằng cách seek offset tương ứng với một timestamp cụ thể trong quá khứ.

MessagingTrung bình2026-07-08
Replay Message Từ Một Thời Điểm Trong Quá Khứ

Tags

#kafka#replay#offset#seek#reprocessing

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

Ngữ nghĩa timestamp trong Kafka (event time vs log-append time)

Mỗi record Kafka có một timestamp: do producer gán (CreateTime, tức event time) hoặc do broker gán khi append vào log (LogAppendTime, tức ingestion time). Cấu hình message.timestamp.type của topic quyết định seek theo thời gian trả về gì và khi nào một segment đủ tuổi để bị xoá theo retention.ms.

#kafka#timestamp#retention#seek
MessagingTrung bình

Bootstrap consumer mới từ snapshot + tail log (thay vì replay từ đầu)

Một service mới cần toàn bộ state của một topic nhiều terabyte; replay lại từ offset 0 mất nhiều ngày và làm quá tải broker. Giải pháp: nạp snapshot (compacted view hoặc export DB) tại một offset đã biết, rồi tail log ngay từ offset đó — không để hở khoảng trống, không nhân trùng vô hạn.

#kafka#bootstrap#snapshot#offset
MessagingNâng cao

Apache Kafka: Partition, consumer group và offset

Kafka phân phối record theo key vào các partition (log append-only có offset), sao chép qua ISR, và để nhiều consumer group đọc song song độc lập — pub/sub ở quy mô lớn.

#kafka#pub-sub#partition#consumer-group