kafka

type ConsumerConfig struct {
	Topic    string        // 消费主题
	Offset   int64         // -1 OffsetNewest -2 OffsetOldest
	Interval time.Duration // 分区刷新周期

	// 自动重试配置
	MaxRetry   int           // 最大重试次数
	MinBackoff time.Duration // 最小避让时间
	MaxBackoff time.Duration // 最大避让时间
}

type ConsumerGroupHander struct {
	Msg chan *sarama.ConsumerMessage
}

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

type KafkaConfig struct {
	Addrs       []string      `yaml:"addrs" json:"addrs" ini:"addrs,omitempty"`
	Version     string        `yaml:"version" json:"version" ini:"version"` // kafka版本
	Sasl        bool          `yaml:"sasl" json:"sasl" ini:"sasl"`
	User        string        `yaml:"user" json:"user" ini:"user"`
	Password    string        `yaml:"password" json:"password" ini:"password"`
	Mechanism   string        `yaml:"mechanism" json:"mechanism" ini:"mechanism"`
	Offset      int64         `yaml:"offset" json:"offset" ini:"offset"`                // 默认从最新开始消费 -1 -2从最后
	MaxRetry    int           `yaml:"max_retry" json:"max_retry" ini:"max_retry"`       // 生产消息失败，默认重试3次
	Timeout     time.Duration `json:"timeout" yaml:"timeout" ini:"timeout"`             // 超时时间
	Compression bool          `json:"compression" yaml:"compression" ini:"compression"` // 发送消息是否开启压缩
	// 这里的kafka无复杂业务，可以用下方的相关配置
	ProducerMessage ProducerMessage `json:"producer_message" yaml:"producer_message" ini:"producer_message"`
	// 生产者配置
	//消费者配置
	GroupName string `json:"group_name" yaml:"group_name" ini:"group_name"`
}

type ProducerMessage struct {
	Topic  string            `json:"topic" yaml:"topic" ini:"topic"`
	Key    string            `json:"key" yaml:"key" ini:"key"`
	Header map[string]string `json:"header" yaml:"header" ini:"header"`
	Role   string            `json:"role" yaml:"role" ini:"role"` // 同步生产者 或者异步生产者
}