kafkaconsumer

type KafkaConsumer struct {
	segments.BaseSegment
	Server string // required
	Topic  string // required
	Group  string // required
	User   string // required if auth is true
	Pass   string // required if auth is true
	Tls    bool   // optional, default is true
	Auth   bool   // optional, default is true
}