proto.lib

Kafka Consumer Rebalance

Minh họa quá trình rebalance trong Kafka consumer group: gán lại partition, cooperative sticky rebalance để tránh dừng toàn bộ group.

MessagingNâng cao2026-07-02
Kafka Consumer Rebalance

Tags

#kafka#consumer-group#rebalance#partition

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