THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
We could even provide a stream.balancing.factor for the user to configure. The smaller this number sets to, the more strict the assignment will behave. If the factor is set to r, the number of tasks a host could own is (w/total tasks)
As we could see, there should be only exactly one learner task after each round of rebalance, and there should be exactly one corresponding active task at the same time.
...