proto.lib

Kafka Cooperative Incremental Rebalance

Cơ chế rebalance tăng dần cho phép consumer group cân bằng lại partition mà không cần dừng toàn bộ consumer cùng lúc như stop-the-world rebalance cũ.

MessagingTrung bình2026-07-08
Kafka Cooperative Incremental Rebalance

Tags

#kafka#consumer-group#rebalance#cooperative-sticky#kip-429

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

max.poll.interval.ms: vòng lặp rebalance vô tận

Coordinator kỳ vọng consumer gọi poll() trong vòng max.poll.interval.ms; nếu một batch xử lý quá lâu và bỏ lỡ mốc này, consumer bị coi là chết, partition bị revoke, commit bị từ chối, việc được giao lại — và consumer mới nhận cũng xử lý chậm y hệt, tạo vòng lặp rebalance không tiến triển.

#kafka#max-poll-interval-ms#consumer-group#rebalance
MessagingTrung bình

Kafka Sticky Partition Assignment

Chiến lược sticky assignor giữ nguyên phân công partition cũ khi rebalance để giảm số lượng partition bị di chuyển giữa các consumer.

#kafka#rebalance#sticky-assignor#consumer-group
MessagingTrung bình

Kafka Static Membership - Tránh Rebalance thừa

Static membership gán group.instance.id cố định cho consumer, giúp Kafka nhận diện lại consumer sau khi restart ngắn mà không kích hoạt rebalance toàn group.

#kafka#static-membership#rebalance#consumer-group