kafkax

type AsyncProducer struct {
	sarama.AsyncProducer
}

type Consumer struct {
	sarama.ConsumerGroup
	// contains filtered or unexported fields
}

type ConsumerConf struct {
	Brokers          string `yaml:"brokers"      json:"brokers"`
	Version          string `yaml:"version"      json:"version"`
	Group            string `yaml:"group"        json:"group"`
	ClientID         string `yaml:"clientID"     json:"clientID"`
	Oldest           bool   `yaml:"oldest"       json:"oldest"`
	MaxWaitTimeMs    int64  `yaml:"maxWaitTimeMs"    json:"maxWaitTimeMs"`    //fetch.wait.max.ms
	SessionTimeoutMs int64  `yaml:"sessionTimeoutMs" json:"sessionTimeoutMs"` //session.timeout.ms
	KeepAliveMs      int64  `yaml:"keepAliveMs"  json:"keepAliveMs"`

	Logger sarama.StdLogger
}

type ConsumerMessage struct {
	*sarama.ConsumerMessage
}

type ProducerConf struct {
	Hosts        string `yaml:"hosts"        json:"hosts"`
	ClientID     string `yaml:"clientID"     json:"clientID"`
	KeepAliveMs  int64  `yaml:"keepAliveMs"  json:"keepAliveMs"`
	ReqTimeoutMs int64  `yaml:"reqTimeoutMs" json:"reqTimeoutMs"`
	RetSuccesses bool   `yaml:"retSuccesses" json:"retSuccesses"`
}

type SyncProducer struct {
	sarama.SyncProducer
}