broker_utils.consumer_sim