...
Stable
: Group offsets will not expire in this state . The fieldempty_state_timestamp
isLong.MaxValue
.(group state ≠Empty
)PreparingRebalance
: Group offsets will not expire in this state. The fieldempty_state_timestamp
isLong.MaxValue
.state (group state ≠Empty
)CompletingRebalance
: Group offsets will not expire in this state. The fieldempty_state_timestamp
isLong.MaxValue
.state (group state ≠Empty
)Empty
: The fieldemptycurrent_state_timestamp
is set to when group last transitioned to this state. If the group stays in this foroffsets.retention.minutes
, the following offset cleanup scheduled task will remove all offsets in the group (as explained above).Dead
: Group offsets have expired (group deletion); or the group is unloaded from the coordinator cache (coordinator change). No offset expiration action required.
The default retention time for group offsets can be customized through the existing offsets.retention.minutes
broker configuration. If, in the future, a need arises for enforcing a per group retention configuration, it can be implemented via a separate KIP.
...