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
	StartAt string // optional, one of "oldest" or "newest", default is "newest"
	// contains filtered or unexported fields
}