proto.lib

Kinesis Enhanced Fan-Out

Enhanced fan-out của Kinesis Data Streams cấp cho mỗi consumer một throughput riêng 2MB/s/shard qua HTTP/2 push, thay vì chia sẻ 2MB/s giữa tất cả consumer.

MessagingTrung bình2026-07-14
Kinesis Enhanced Fan-Out

Tags

#kinesis#enhanced-fan-out#consumer#http2#throughput

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

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

RabbitMQ Single Active Consumer: một tiêu thụ, dự phòng nóng

Nhiều consumer cùng đăng ký vào một hàng đợi nhưng chỉ MỘT được broker cho phép nhận message tại một thời điểm; khi consumer đang active ngắt kết nối, broker tự động thăng cấp consumer kế tiếp — giữ thứ tự chặt trong hàng đợi và failover nhanh mà không có split-brain của việc hai consumer cùng xử lý.

#rabbitmq#single-active-consumer#ordering#failover
MessagingTrung bình

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

#benchmark#methodology#throughput#latency-distribution