Flowcharts & Processes

Kafka Consumer Rebalance Flow

Flowcharts & Algorithms diagram · made in Skemio

Flowchart mapping Kafka rebalance: heartbeat timeout, mark consumer dead, coordinator triggers rebalance, members join group, leader assigns partitions, sync group state, and resume consumption.
Flowchart mapping Kafka rebalance: heartbeat timeout, mark consumer dead, coordinator triggers rebalance, members join group, leader assigns partitions, sync group state, and resume consumption.
Open it in SkemioMake your own

What it shows

  • Heartbeat failures cause the Group Coordinator to mark a consumer dead.
  • JoinGroup syncs active members and elects a Group Leader.
  • Incremental cooperative rebalancing avoids full stop-the-world partitions pauses.

The takeaway

Tune heartbeat and max poll intervals to stop accidental rebalance storms under load.

More flowcharts & algorithms diagrams