code: func (p *Plugin) getClientConfig(config *mux.Config, logger logging.Logger, topic string) (*client.Config, error) {
  	clientCfg := client.NewConfig(logger)
  	// Set brokers obtained from kafka config. In case there are none available, use a default one
  	if len(config.Addrs) > 0 {
  		clientCfg.SetBrokers(config.Addrs...)
  	} else {
  		clientCfg.SetBrokers(mux.DefAddress)
  	}
  	// Set group ID obtained from kafka config. In case there is none, use a service label
  	if config.GroupID != "" {
  		clientCfg.SetGroup(config.GroupID)
  	} else {
  		clientCfg.SetGroup(p.ServiceLabel.GetAgentLabel())
  	}
  	clientCfg.SetRecvMessageChan(p.subscription)
  	clientCfg.SetInitialOffset(sarama.OffsetNewest)
  	clientCfg.SetTopics(topic)
  	if config.TLS.Enabled {
  		p.Log.Info("TLS enabled")
  		tlsConfig, err := clienttls.CreateTLSConfig(config.TLS)
  		if err != nil {
  			return nil, err
  		}
  		clientCfg.SetTLS(tlsConfig)
  	}
  	return clientCfg, nil
  }
docs: // Receive client config according to kafka config data