kafka

type CommonConfig struct {
	Brokers  []string // broker 列表
	ClientID string   // 客户端 ID

	// TLS 配置
	TLS        bool
	CACert     string
	ClientCert string
	ClientKey  string

	// SASL 配置
	SASLMechanism string
	SASLUser      string
	SASLPass      string

	EnableTrace bool
}

type ConsumeManager struct {
	CallBack map[string]Handler
	// contains filtered or unexported fields
}

type Consumer struct {
	Handler Handler
	// contains filtered or unexported fields
}

type ConsumerConfig struct {
	CommonConfig        `json:"CommonConfig"`
	Topic               []string
	GroupID             string
	AutoCommit          bool
	BlockRebalance      bool
	ConsumerChannelSize int
	DLQChannelSize      int
}

type Handler interface {
	Handle(record kgo.FetchTopicPartition) error
}

type NewTopic struct {
	Topic             string
	Partition         int32
	ReplicationFactor int16
	Configs           map[string]*string
}

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

type ProducerConfig struct {
	CommonConfig           `json:"CommonConfig"`
	Topic                  []string
	Compression            string
	RetryMax               int
	AllowAutoTopicCreation bool
}

type ProducerInterface interface {
	Produce(ctx context.Context, r *kgo.Record, cb func(*kgo.Record, error))
	Close()
}