package message

import (
	"gitlab.fjmaimaimai.com/mmm-go/partner/pkg/infrastructure/message/kafkax"
	"gitlab.fjmaimaimai.com/mmm-go/partner/pkg/infrastructure/message/models"
)

//新消费者-消费组
func NewConsumer(kafkaHosts string, groupId string) models.Consumer {
	return kafkax.NewSaramaConsumer(kafkaHosts, groupId)
}