Add a goroutine to offload the Kafka errChan processing and prevent deadlocks