queue

type ConsumerConfig struct {
	Brokers        []string
	SaslConfig     *SaslConfig
	Topic          string
	GroupID        string
	ConsumerOffset int64
}

type ProducerConfig struct {
	Brokers    []string
	SaslConfig *SaslConfig
	Topic      string
	BatchSize  int
	BatchBytes int
	Balancer   string
}

type SaslConfig struct {
	SaslMechanism string
	SaslUsername  string
	SaslPassword  string
	KafkaCA       string
}