Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Upon each partition assignment calculation, the full partition assignments are preserved for each consumer (as user data). The embedded protocol used by consumer groups opting the sticky partition assignment would be

ProtocolName => "sticky"
 
ProtocolMetadata => Version Subscription UserData
  Version => int16
  Subscription => [Topic]
    Topic => string
  UserData => CurrentAssignments
    CurrentAssignments => [Topic [Partition]]
      Topic => string
      Partition => int32

 

This is specially helpful when a consumer group leader, who is in charge of performing the partition assignment, dies and the leadership has to be given to some other group member. In such circumstances, the new leader has access to the most recent partition assignment and can easily take over the rebalance that is triggered when the former leader disappears, and also as well as future rebalances.

 

Example 1

...