MQBrokerException: CODE: 1 DESC: the topic[XXX] is batch send , not support

alibaba / canal

阿里巴巴 MySQL binlog 增量订阅&消费组件

Apache License 2.0

28.53k stars 7.62k forks source link

MQBrokerException: CODE: 1 DESC: the topic[XXX] is batch send , not support #3407

Open c2ch opened 3 years ago

c2ch commented 3 years ago

Question

使用阿里云RocketMq同步到es中，canal版本1.1.5 ，报如下错误： java.lang.RuntimeException: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 1 DESC: the topic[XXX] is batch send , not support. For more information, please visit the url, http://rocketmq.apache.org/docs/faq/ com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.sendMessage(CanalRocketMQProducer.java:308)

c2ch commented 3 years ago

阿里云RocketMq不支持批量发送？？

nikolabai commented 3 years ago

我也遇到了同样的问题，用的flatmessage模式，你解决了吗

c2ch commented 3 years ago

我也遇到了同样的问题，用的flatmessage模式，你解决了吗

没有，换成kafka了。