code: func (k *KafkaMdm) Stop() {
  	// closes notifications and messages channels, amongst others
  	close(k.shutdown)
  	k.wg.Wait()
  	k.client.Close()
  }
docs: // Stop will initiate a graceful stop of the Consumer (permanent)
  // and block until it stopped.