refactor test to consume after all messages are produced
group fix
tmp test