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 index bdab8a72..74d80671 100644 --- 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 @@ public class CanalRocketMQProducer extends AbstractMQProducer implements CanalMQ } 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 index 91a21811..b208d514 100644 --- 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.slf4j.LoggerFactory; 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 index afe7d524..6f5a73c6 100644 --- 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.client.rocketmq.RocketMQCanalConnector; import com.alibaba.otter.canal.protocol.FlatMessage; /** - * Kafka client example + * RocketMQ client example * * @author machengyuan @ 2018-6-12 * @version 1.0.0