zangjietutu
zangjietutu
升级到1.1.7 后 将配置 改成如下: #canal.mq.partitionsNum=1 注释掉了，想依靠 canal.mq.enableDynamicQueuePartition 自动获取分区数，但是会有如下 报错： ` 2023-12-05 11:38:04.323 [pool-4-thread-1] ERROR c.a.o.c.c.rocketmq.producer.CanalRocketMQProducer - java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.NullPointerException java.lang.RuntimeException: java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.NullPointerException at com.alibaba.otter.canal.common.utils.ExecutorTemplate.waitForResult(ExecutorTemplate.java:74) at com.alibaba.otter.canal.connector.rocketmq.producer.CanalRocketMQProducer.send(CanalRocketMQProducer.java:168) at com.alibaba.otter.canal.connector.core.spi.ProxyCanalMQProducer.send(ProxyCanalMQProducer.java:51) at...
当我把 注释放开 canal.mq.partitionsNum=1， 我猜估计上次报空指针是因为 无法自动获取分区数，然后我又把 canal.mq.partitionsNum=1注释掉了的原因，这次注释放开后，果然不报空指针了。报以下错误： ` 2023-12-05 12:04:28.366 [pool-4-thread-1] ERROR c.a.o.c.c.rocketmq.producer.CanalRocketMQProducer - java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.RuntimeException: java.util.concurrent.ExecutionException: java.lang.RuntimeException: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 3 DESC: request code unsupported, code 320 BROKER: 172.16.16.12:8080 For...