kafkaconfluent

type Config struct {
	Brokers  []string
	GroupID  string
	Username string
	Password string

	Topics []string

	// PoolTimeout is the value passed to the internal consumer.Pool(...)
	// function. Default: 1s
	PoolTimeout time.Duration
	// contains filtered or unexported fields
}