kafkaconsumer

type Handler struct {
	// contains filtered or unexported fields
}

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"
	Timeout time.Duration // optional, default is 15s, any parsable duration
	// contains filtered or unexported fields
}