This commit is contained in:
nick
2021-10-09 14:53:28 +08:00
committed by GitHub
parent d79431c7e5
commit 31a0fdc807
3 changed files with 3 additions and 2 deletions

View File

@@ -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);

View File

@@ -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

View File

@@ -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