types

type Config struct {
	Brokers                []string
	Topic                  string
	BalanceStrategy        string
	MaxAttempts            int
	WriteBackoffMin        time.Duration
	WriteBackoffMax        time.Duration
	BatchSize              int
	BatchBytes             int
	BatchTimeout           time.Duration
	ReadTimeout            time.Duration
	WriteTimeout           time.Duration
	RequiredAcks           int16
	Async                  bool
	Compression            string
	Logger                 *log.Logger
	ErrorLogger            *log.Logger
	AllowAutoTopicCreation bool
}