This can be problematic if there is no "next attempt", i.e. the stream goes idle for a long time.

We can setup callbacks on the group consumer in the product code to know when the rebalance has finished.