From 0ff882bd4d1d0054ce9d261abef21fa6da3bcfe5 Mon Sep 17 00:00:00 2001 From: zhangjidi2016 Date: Wed, 14 Apr 2021 11:16:25 +0800 Subject: [PATCH] [ISSUE #2801]Fix NamesrvAddr connot set in Producer --- .../java/org/apache/rocketmq/example/ordermessage/Producer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java b/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java index 6a6bdc7d..ba8ef4d5 100644 --- a/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java +++ b/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java @@ -32,7 +32,7 @@ import org.apache.rocketmq.remoting.exception.RemotingException; public class Producer { public static void main(String[] args) throws UnsupportedEncodingException { try { - MQProducer producer = new DefaultMQProducer("please_rename_unique_group_name"); + DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name"); producer.start(); String[] tags = new String[] {"TagA", "TagB", "TagC", "TagD", "TagE"}; -- GitLab