kafkaconfluent

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

	// RDKafkaConfig can specify librdkafka configs. If this is variable is set, the
	// other variables (Brokers, GroupID, Username and Password) are ignored
	RDKafkaConfig *kafka.ConfigMap

	Topics []string

	// PoolTimeout is the value passed to the internal consumer.Pool(...)
	// function. Default: 1s
	PoolTimeout time.Duration

	// DisableCommit indicates that offsets should never be commited, even
	// after calling Done()
	DisableCommit bool
}