Monitor consumer workers and restart them if necessary