proto.lib

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.

MessagingTrung bình2026-08-20
Buffer producer đầy: send() chặn cả thread request

Tags

#kafka#producer#buffer-memory#backpressure#max-block-ms#thread-exhaustion

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

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.

#kafka#producer#in-flight-requests#retries
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
MessagingTrung bình

Idempotent Producer - Sequence Numbers

Producer idempotent gắn producer ID và sequence number cho mỗi message để broker phát hiện và loại bỏ bản ghi trùng do retry.

#kafka#idempotency#producer#sequence-number