Hey Dan, Thanks for looking into this. Are you talking about MockConsumer? If you invoke subscribe(Collection<String> topics), it actually registers a Noop callback. Perhaps this is what you are seeing?
P On Thu, Mar 23, 2023 at 11:11 AM Dan S <danielms...@gmail.com> wrote: > 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 >
