THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Tag Name | Task Type | Explanation |
---|---|---|
isStateful | both | Indicate whether given task has a state to restore. |
isLearner | standby | Indicate whether standby task is a learner task. |
beingLearned | active | Indicate whether active task is being learned by some other stream worker. |
isReady | standby | Indicate whether standby task is ready to serve as active task. |
isLeaving | active | Indicate whether active task will be leaving the group soon. |
Assignment Algorithm
The above examples are focusing more on demonstrating expected behaviors with KStream incremental rebalancing "end picture". However, we also want to have a holistic view of the new learner assignment algorithm during each actual rebalance.
...