kafka

type Compression string

type Config struct {
	Addrs []string `mapstructure:"addrs"` // Kafka服务器地址列表

	// 生产者配置
	Producer ProducerConfig `mapstructure:"producer"`
	// 消费者配置
	Consumer ConsumerConfig `mapstructure:"consumer"`
}

type ConsumeHandlerFunc func(sarama.ConsumerGroupSession, sarama.ConsumerGroupClaim) error

type ConsumerConfig struct {
	GroupID        string         `mapstructure:"group_id"`                                                           // 消费者组ID
	GroupRebalance GroupRebalance `mapstructure:"group_rebalance" validate:"omitempty,oneof=range roundrobin sticky"` // 消费者组重新分配策略（当有消费者退出时） 默认 GroupRebalanceRange
	OffsetInitial  Offset         `mapstructure:"offset_initial" validate:"omitempty,oneof=oldest newest"`            // 初始offset 默认 OffsetNewest
	// 最长等待时间，当 MinBytes 还未满足时，最多等待多久再返回数据 默认 250ms
	MaxWaitTime types.Duration `mapstructure:"max_wait_time"` // 最大等待时间
	// 最小拉取字节数，如果消息小于该值，Kafka 可能会等待 默认 1 B
	MinBytes types.ByteSize `mapstructure:"min_bytes"`
	// 最大拉取字节数， 一次 fetch 请求最多拉取多少数据  默认 1MB                                                        // 最小获取字节数
	MaxBytes types.ByteSize `mapstructure:"max_bytes"` // 最大获取字节数
}

type ConsumerInfo struct {
	Handler ConsumeHandlerFunc
	Mode    ConsumerMode
}

type ConsumerMode int

type GroupRebalance string

type Offset string

type ProducerConfig struct {
	// 重试配置
	Retry RetryConfig `mapstructure:"retry"`

	// 发送配置
	RequiredAcks RequiredAcks   `mapstructure:"required_acks" validate:"omitempty,oneof=none local all"`     // 需要的ack数量
	Timeout      types.Duration `mapstructure:"timeout"`                                                     // 发送超时时间
	Compression  Compression    `mapstructure:"compression" validate:"omitempty,oneof=none gzip snappy lz4"` // 压缩算法
}

type ProducerOpt func(o *ProducerOpts)

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

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

type RequiredAcks string

type RetryConfig struct {
	Max     int            `mapstructure:"max" validate:"gte=0"` // 最大重试次数
	Backoff types.Duration `mapstructure:"backoff"`              // 重试间隔
}

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

type Subscriber struct {
	*ConsumerInfo
	Topic string
}