Group.run only returns after all consumers are running