Fixed thread exception handling in consumer