cons

Jun 5, 2024

Changes in this version

+ type Consumer struct

+ func New() *Consumer

+ func (this *Consumer) NewConsumer(servers []string, groupName string) error

+ func (this *Consumer) NewCustomConsumer(opts ...consumer.Option) error

+ func (this *Consumer) Shutdown() error

+ func (this *Consumer) Start() error

+ func (this *Consumer) Subscribe(topic string, _receiver OnReceiver) error

+ type OnReceiver func(msg *primitive.MessageExt)