code: func (ref *Consumer) errorHandler(in <-chan error) {
  	ref.Debug("errorHandler started ...")
  	for {
  		select {
  		case err, more := <-in:
  			if more {
  				ref.Errorf("message error: %T, %v", err, err)
  				ref.Config.RecvErrorChan <- err
  			}
  		case <-ref.closeChannel:
  			ref.Debug("Canceling error handler")
  			return
  		}
  	}
  }
docs: // errorHandler processes each error message