code: func NewConsumerConf(topic string, partition int32) ConsumerConf {
  	return ConsumerConf{
  		Topic:          topic,
  		Partition:      partition,
  		RequestTimeout: time.Millisecond * 50,
  		RetryLimit:     -1,
  		RetryWait:      time.Millisecond * 50,
  		RetryErrLimit:  10,
  		RetryErrWait:   time.Millisecond * 500,
  		MinFetchSize:   1,
  		MaxFetchSize:   2000000,
  		StartOffset:    StartOffsetOldest,
  		Logger:         nil,
  	}
  }
docs: // NewConsumerConf returns the default consumer configuration.