proto.lib

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.

MessagingTrung bình2026-08-20
max.poll.interval.ms: vòng lặp rebalance vô tận

Tags

#kafka#max-poll-interval-ms#consumer-group#rebalance#poll-loop#worker-pool

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

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
MessagingTrung bình

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

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