ingest

type KafkaConfig struct {
	Brokers           []string     `yaml:"brokers,omitempty" json:"brokers,omitempty" doc:"list of kafka broker addresses"`
	Topic             string       `yaml:"topic,omitempty" json:"topic,omitempty" doc:"kafka topic to listen on"`
	GroupId           string       `yaml:"groupid,omitempty" json:"groupid,omitempty" doc:"separate groupid for each consumer on specified topic"`
	GroupBalancers    []string     `` /* 132-byte string literal not displayed */
	StartOffset       string       `` /* 161-byte string literal not displayed */
	BatchReadTimeout  int64        `yaml:"batchReadTimeout,omitempty" json:"batchReadTimeout,omitempty" doc:"how often (in milliseconds) to process input"`
	BatchMaxLen       int          `` /* 133-byte string literal not displayed */
	PullQueueCapacity int          `` /* 127-byte string literal not displayed */
	PullMaxBytes      int          `yaml:"pullMaxBytes,omitempty" json:"pullMaxBytes,omitempty" doc:"the maximum number of bytes being pulled from kafka"`
	CommitInterval    int64        `` /* 192-byte string literal not displayed */
	TLS               *clients.TLS `yaml:"tls,omitempty" json:"tls" doc:"TLS client configuration (optional)"`
	ChannelBufLen     int          `yaml:"chanBufLen" json:"chanBufLen"`
}