proto.lib

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

MessagingCơ bản2026-08-20
auto.offset.reset: khi consumer không có offset hợp lệ

Tags

#kafka#auto-offset-reset#consumer-offset#retention#offset-out-of-range#operations

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
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
MessagingNâng cao

Kafka Partition Reassignment - Di chuyển dữ liệu

Admin dùng công cụ reassign-partitions để di chuyển replica sang broker mới, controller điều phối copy dữ liệu trước khi xóa bản cũ.

#kafka#partition-reassignment#controller#rebalancing