code: func NewBrokerConf(clientID string) BrokerConf {
  	return BrokerConf{
  		ClientID:           clientID,
  		DialTimeout:        10 * time.Second,
  		DialRetryLimit:     10,
  		DialRetryWait:      500 * time.Millisecond,
  		AllowTopicCreation: false,
  		LeaderRetryLimit:   10,
  		LeaderRetryWait:    500 * time.Millisecond,
  		RetryErrLimit:      10,
  		RetryErrWait:       time.Millisecond * 500,
  		ReadTimeout:        30 * time.Second,
  		Logger:             &nullLogger{},
  	}
  }
docs: // NewBrokerConf returns the default broker configuration.