code: func (ref *Consumer) StartConsumerHandlers() {
  	config := ref.Config
  	config.Logger.Info("Starting message handlers for new consumer ...")
  	// if required, start reading from the notifications channel
  	if config.ConsumerConfig().Group.Return.Notifications {
  		go ref.notificationHandler(ref.Consumer.Notifications())
  	}
  
  	// if required, start reading from the errors channel
  	if config.ProducerConfig().Consumer.Return.Errors {
  		go ref.errorHandler(ref.Consumer.Errors())
  	}
  
  	// start the message handler
  	go ref.messageHandler(ref.Consumer.Messages())
  }
docs: // StartConsumerHandlers starts required handlers using bsm/sarama consumer. Used when partitioner set in config is
  // non-manual