code: func (k *Kafka) Stop() error {
  	k.mutex.Lock()
  	if k.stopped {
  		k.mutex.Unlock()
  		return errors.Errorf("container %s already stopped", k.ContainerID)
  	}
  	k.stopped = true
  	k.mutex.Unlock()
  
  	return k.Client.StopContainer(k.ContainerID, 0)
  }
docs: // Stop stops and removes the Kafka container