diff --git a/docs/cn/RocketMQ_Example.md b/docs/cn/RocketMQ_Example.md index 5728ed4f47791d0a7561bda67eddbe57ae246c9a..f45221f99fd5016154501b1b0851b245c45dfa1b 100644 --- a/docs/cn/RocketMQ_Example.md +++ b/docs/cn/RocketMQ_Example.md @@ -38,8 +38,8 @@ public class SyncProducer { // 启动Producer实例 producer.start(); for (int i = 0; i < 100; i++) { - // 创建消息,并指定Topic,Tag和消息体 - Message msg = new Message("TopicTest" /* Topic */, + // 创建消息,并指定Topic,Tag和消息体 + Message msg = new Message("TopicTest" /* Topic */, "TagA" /* Tag */, ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */ );