Versions Compared

Old Version 29

changes.mady.by.user Philip Nee

Saved on

compared with

New Version 30

changes.mady.by.user Philip Nee

Saved on

Key

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

...

  1. We split the PREPARING_REBALANCE into PREPARE_REVOCATION, and PARTITION_REVOKED, PREPARING_REBALANCE

    1. PREPARE_REVOCATION: Pause partitions that will be reovkedrevoked

    2. REVOKING_PARTITION: Send a PARTITION_REVOKE event to the polling threadAwait for the onPartitionRevoked to be compelted.

    3. PARTITION_REVOKED: Update the subscription.  Autocommit.

  2. STABLE will become ASSIGNING_PARTITIONS and STABLE And ASSIGN_PARTITION state will be added before STABLE

    1. ASSIGNING_PARTITIONS: Send an ASSIGN_PARTITIONS event

      STABLE: Upon receiving PARTITIONS_ASSIGNED event, transition to STABLE

      Await for onPartitionAssign to be completed.

Image Added

After the proposed state transition is as such:

...