code: func watchChannels(consumer *client.Consumer, cfg *client.Config) {
  
  	for {
  		select {
  		case notification, more := <-cfg.RecvNotificationChan:
  			if more {
  				handleNotifcation(consumer, notification)
  			}
  		case err, more := <-cfg.RecvErrorChan:
  			if more {
  				fmt.Printf("Message Recv Errored: %v\n", err)
  			}
  		case msg, more := <-cfg.RecvMessageChan:
  			if more {
  				messageCallback(consumer, msg, *commit)
  			}
  		case <-consumer.GetCloseChannel():
  			return
  		}
  	}
  }
docs: // watchChannels watches channels configured for delivery of Kafka messages,
  // notifications and errors.