THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
When a processor in the socketServer sends a StopRequest to a consumer's channel to inform it to stop consuming and wait for the new assigned partitions due to rebalance, it needs to initializes a expire watcher for the request, and when .
When it received the corresponding StartResponse from the channel, it needs to clear the watcher. For a detailed description of the request expire/satisfy purgatory, please read here.
...