fkafka

type ClientConfig struct {
	Brokers      []string // Brokers brokers地址
	AuthType     string   // 鉴权方式, password / none. 默认为: none
	SaslUsername string   // 鉴权方式为 password 时, 必填
	SaslPassword string   // 鉴权方式为 password 时, 必填
	Version      string   // kafka version, 默认为 2.0.0.0
}

type Config struct {
	Debug                      bool
	EnableAccessInterceptorReq bool // 是否开启记录 publish 消息，默认开启
	EnableAccessInterceptorRes bool // 是否开启记录 consumer 消费消息, 默认开启

	ClientConfig         ClientConfig
	ProducerConfig       ProducerConfig
	ConsumerGroupConfigs map[string]ConsumerGroupConfig
}

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

type ConsumerGroupConfig struct {
	Topics        []string
	GroupID       string
	InitialOffset string // 初始化 offset, oldest / newest, 默认 oldest
	RetryConfig   RetryConfig
}

type Handler func(ctx context.Context, message *sarama.ConsumerMessage) error

type Message struct {
	Topic string
	Key   []byte
	Value []byte
	// The headers are key-value pairs that are transparently passed
	// by Kafka between producers and consumers.
	Headers []sarama.RecordHeader

	// This field is used to hold arbitrary data you wish to include, so it
	// will be available when receiving on the Successes and Errors channels.
	// Sarama completely ignores this field and is only to be used for
	// pass-through data.
	Metadata interface{}
}

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

type ProducerConfig struct {
	MaxMessageBytes int
}

type RetryConfig struct {
	MaxRetries int64 // consumer 消费重试次数, 默认 0 不重试
}