proto.lib

Phương pháp Benchmark Message Broker cho đúng

Một benchmark broker phải công bố kích thước message, mức acks/durability, số partition và số producer/consumer, page cache đã warm hay chưa, và thời gian chạy có đủ để retention/compaction thật sự xảy ra hay không — vì một test 30 giây với message nhỏ và không durability không đo được gì có ý nghĩa trong thực tế.

MessagingTrung bình2026-08-25
Phương pháp Benchmark Message Broker cho đúng

Tags

#benchmark#methodology#throughput#latency-distribution#durability#acks

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

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

Tinh chỉnh fetch của Kafka consumer (fetch.min.bytes / fetch.max.wait.ms)

Consumer Kafka gửi một FetchRequest yêu cầu tối thiểu N byte, và broker chờ tối đa T milliseconds trước khi trả về dù chưa đủ N byte; một request có thể gom nhiều partition, mỗi partition bị chặn bởi max.partition.fetch.bytes và tổng request bị chặn bởi fetch.max.bytes.

#kafka#consumer#fetch-tuning#latency
MessagingTrung bình

Inbound Webhook Ingestion (nhận webhook từ bên thứ ba)

Khi là bên nhận webhook, endpoint phải xác thực chữ ký, trả 2xx NGAY trước khi xử lý bằng cách ghi payload gốc vào một queue bền vững, rồi xử lý bất đồng bộ với dedup theo event id của nhà cung cấp — vì bất cứ độ chậm hay lỗi nào cũng khiến bên gửi retry, gây trùng lặp và cuối cùng vô hiệu hoá endpoint.

#webhook#ingestion#idempotency#queue