THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
We split the PREPARING_REBALANCE into PREPARE_REVOCATION, and PARTITION_REVOKED, PREPARING_REBALANCE
- PREPARE_REVOCATION: Pause partitions that will be reovkedrevoked
REVOKING_PARTITION: Send a PARTITION_REVOKE event to the polling threadAwait for the onPartitionRevoked to be compelted.
- PARTITION_REVOKED: Update the subscription. Autocommit.
STABLE will become ASSIGNING_PARTITIONS and STABLE And ASSIGN_PARTITION state will be added before STABLE
ASSIGNING_PARTITIONS: Send an ASSIGN_PARTITIONS event
STABLE: Upon receiving PARTITIONS_ASSIGNED event, transition to STABLEAwait for onPartitionAssign to be completed.
After the proposed state transition is as such:
...