Versions Compared

Old Version 11

changes.mady.by.user Vahid Hashemian

Saved on

compared with

New Version 12

changes.mady.by.user Vahid Hashemian

Saved on

Key

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

...

  • Stable: Group offsets will not expire in this state . The field empty_state_timestamp is Long.MaxValue.(group state ≠ Empty)
  • PreparingRebalance: Group offsets will not expire in this state. The field empty_state_timestamp is Long.MaxValue.state (group state ≠ Empty)
  • CompletingRebalance: Group offsets will not expire in this state. The field empty_state_timestamp is Long.MaxValue.state (group state ≠ Empty)
  • Empty: The field emptycurrent_state_timestamp is set to when group last transitioned to this state. If the group stays in this for offsets.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.

...