consumer

type Conf struct {
	Type         string   `yaml:"type"`
	Addrs        []string `yaml:"addrs"`
	GroupName    string   `yaml:"group_name"`
	ConsumeModel int      `yaml:"consume_model"`
}

type Consumer interface {
	Shutdown() error
	Subscribe(topic string, callback func(ctx context.Context, msgs ...*mq.MessageExt) (int, error)) error
}