kafkax

type Consumer interface {
	transport.Server                          //跟着gin框架一起启动
	RegisterHandles(MsgHandleFunc, ...string) //注册处理方法
	Subscribe(ctx context.Context)            //开始处理消息，手动开启
}

type ConsumerConfig struct {
	Addr      string
	Channel   string
	ClientID  string
	GroupID   string
	UserName  string
	Password  string
	Mechanism string
	Version   string
	Trace     trace.Tracer
}

type CustomMessage struct {
	Header  RawMessage `json:"header"`
	Payload RawMessage `json:"payload"`
}

type Message struct {
	Topic     string
	Key       string
	Value     []byte
	Timestamp time.Time
}

type MessageHandleDef struct {
	Topic   []string
	Handle  MsgHandleFunc
	Options []Option
}

type MsgHandleFunc func(ctx context.Context, msg *Message) bool

type Option interface {
	// contains filtered or unexported methods
}

type OptionFunc func(*optionConfig)

type Producer interface {
	Send(topic string, value []byte) error
	SendWithKey(topic string, key []byte, value []byte) error
	RetrySend(ctx context.Context, topic string, messageBody []byte) error
	ListTopicGroupIds(topic string) ([]string, error)
	Close() error
}

type ProducerConfig struct {
	Addr      string
	UserName  string
	Password  string
	Mechanism string
	RecSize   int
}

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

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

type RawMessage map[string]any