Hello all, It seems to me based on reading the code, that the consumer rebalance listener that is passed into the mock consumer when subscribing to a topic is not actually called when a rebalance is simulated. My understanding is that the consumer rebalance listener is called from the consumer coordinator, which is called by kafka consumer. The mock consumer doesn't seem to use the consumer coordinator or use any other mechanism to call the consumer rebalance listener. Is my understanding correct? Would it make sense to trigger the consumer rebalance listener when rebalance is called?
I would be willing to try to make the patch if the behavior is indeed currently incorrect/incomplete. Thanks, Daniel
