proto.lib

Retry khi có nhiều batch in-flight: mất thứ tự message

Khi producer cho phép nhiều batch cùng bay tới một partition (max.in.flight.requests.per.connection > 1), một batch đầu bị lỗi và retry có thể đến broker SAU batch thứ hai đã thành công, khiến thứ tự theo key bị đảo ngược âm thầm; idempotent producer dùng sequence number để broker phát hiện và sắp xếp lại đúng.

MessagingTrung bình2026-08-20
Retry khi có nhiều batch in-flight: mất thứ tự message

Tags

#kafka#producer#in-flight-requests#retries#ordering#idempotent-producer

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

Buffer producer đầy: send() chặn cả thread request

Record được gom vào buffer.memory theo từng partition (batching + linger.ms) trước khi gửi; khi broker chậm hoặc leader của một partition không sẵn sàng, buffer đầy lên và send() BLOCK tới max.block.ms rồi ném exception — biến một broker chậm thành cạn kiệt thread ở service gọi.

#kafka#producer#buffer-memory#backpressure
MessagingCơ bản

Partition Key Hashing - Chọn Partition Theo Key

Producer băm (hash) message key để quyết định message đi vào partition nào, đảm bảo các message cùng key luôn vào cùng một partition.

#kafka#partitioning#hashing#message-key
MessagingCơ bản

Kafka Producer Acks - Đánh đổi Durability

So sánh acks=0, acks=1 và acks=all để thấy sự đánh đổi giữa độ trễ và độ bền dữ liệu khi producer ghi vào Kafka.

#kafka#acks#durability#replication