package rocketmq import ( "github.com/apache/rocketmq-client-go/v2" "github.com/apache/rocketmq-client-go/v2/primitive" "github.com/apache/rocketmq-client-go/v2/producer" "log" ) var MqPool rocketmq.Producer func MqConnect(group string, resolver []string) { p, err := rocketmq.NewProducer( producer.WithGroupName(group), producer.WithNsResolver(primitive.NewPassthroughResolver(resolver)), //producer.WithCreateTopicKey("product"), producer.WithRetry(1)) if err != nil { log.Println("New "+group+" producer failed", err) return } err = p.Start() if err != nil { log.Println(group+" producer start failed", err) return } MqPool = p }