Fix the steam consumer and producer