proto.lib

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.

MessagingTrung bình2026-08-25
Ngữ nghĩa timestamp trong Kafka (event time vs log-append time)

Tags

#kafka#timestamp#retention#seek#clock-skew#log-append-time

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

MessagingCơ bản

auto.offset.reset: khi consumer không có offset hợp lệ

Khi consumer group chưa có offset đã commit — hoặc offset đã commit rơi khỏi log do retention (offset-out-of-range) — auto.offset.reset quyết định điểm bắt đầu đọc: latest bỏ qua toàn bộ dữ liệu cũ (consumer mới 'không thấy gì'), earliest đọc lại toàn bộ dữ liệu còn giữ (lụt bản ghi trùng lặp).

#kafka#auto-offset-reset#consumer-offset#retention
MessagingCơ bản

Retention Policy & Dọn Log Segment

Broker tự động xóa hoặc archive các log segment cũ hơn thời gian/kích thước retention cấu hình để giải phóng dung lượng đĩa.

#kafka#retention#log-segment#cleanup
MessagingTrung bình

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ứ.

#kafka#replay#offset#seek