add note (#3550)

nikolabai · web-flow · commit 31a0fdc80765 · 2021-10-09T14:53:28.000+08:00
diff --git a/connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer/CanalRocketMQProducer.java b/connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer/CanalRocketMQProducer.java
@@ -331,6 +331,7 @@ private void sendMessage(List<Message> messages, int partition) {
                 }
 
                 try {
+                    // 阿里云RocketMQ暂不支持批量发送消息，当canal.mq.flatMessage = true时，会发送失败
                     SendResult sendResult = this.defaultMQProducer.send(messages, queue);
                     if (logger.isDebugEnabled()) {
                         logger.debug("Send Message Result: {}", sendResult);
diff --git a/example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientExample.java b/example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientExample.java
@@ -9,7 +9,7 @@
 import org.springframework.util.Assert;
 
 /**
- * Kafka client example
+ * RocketMQ client example
  *
  * @author machengyuan @ 2018-6-12
  * @version 1.0.0
diff --git a/example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientFlatMessageExample.java b/example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientFlatMessageExample.java
@@ -11,7 +11,7 @@
 import com.alibaba.otter.canal.protocol.FlatMessage;
 
 /**
- * Kafka client example
+ * RocketMQ client example
  *
  * @author machengyuan @ 2018-6-12
  * @version 1.0.0

Original file line number	Diff line number	Diff line change
`@@ -331,6 +331,7 @@ private void sendMessage(List<Message> messages, int partition) {`
`331`	`331`	`}`
`332`	`332`
`333`	`333`	`try {`
	`334`	`+ // 阿里云RocketMQ暂不支持批量发送消息，当canal.mq.flatMessage = true时，会发送失败`
`334`	`335`	`SendResult sendResult = this.defaultMQProducer.send(messages, queue);`
`335`	`336`	`if (logger.isDebugEnabled()) {`
`336`	`337`	`logger.debug("Send Message Result: {}", sendResult);`
Original file line number	Diff line number	Diff line change
`@@ -9,7 +9,7 @@`
`9`	`9`	`import org.springframework.util.Assert;`
`10`	`10`
`11`	`11`	`/**`
`12`		`- * Kafka client example`
	`12`	`+ * RocketMQ client example`
`13`	`13`	`*`
`14`	`14`	`* @author machengyuan @ 2018-6-12`
`15`	`15`	`* @version 1.0.0`
Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,7 @@`
`11`	`11`	`import com.alibaba.otter.canal.protocol.FlatMessage;`
`12`	`12`
`13`	`13`	`/**`
`14`		`- * Kafka client example`
	`14`	`+ * RocketMQ client example`
`15`	`15`	`*`
`16`	`16`	`* @author machengyuan @ 2018-6-12`
`17`	`17`	`* @version 1.0.0`