数据库版本：5.7.33
canal版本：1.1.7
我的canal从1.1.4升级到1.1.7，几天运行后出现如下报错：
2024-07-20 10:17:02.923 [pool-4-thread-2] ERROR c.a.o.canal.connector.kafka.producer.CanalKafkaProducer - java.util.concurrent.ExecutionException: java.lang.OutOfMemoryError
java.lang.RuntimeException: java.util.concurrent.ExecutionException: java.lang.OutOfMemoryError
at com.alibaba.otter.canal.common.utils.ExecutorTemplate.waitForResult(ExecutorTemplate.java:74)
at com.alibaba.otter.canal.connector.kafka.producer.CanalKafkaProducer.send(CanalKafkaProducer.java:165)
at com.alibaba.otter.canal.connector.core.spi.ProxyCanalMQProducer.send(ProxyCanalMQProducer.java:51)
at com.alibaba.otter.canal.server.CanalMQStarter.worker(CanalMQStarter.java:181)
at com.alibaba.otter.canal.server.CanalMQStarter.access$100(CanalMQStarter.java:24)
at com.alibaba.otter.canal.server.CanalMQStarter$CanalMQRunnable.run(CanalMQStarter.java:223)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.ExecutionException: java.lang.OutOfMemoryError
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.alibaba.otter.canal.common.utils.ExecutorTemplate.waitForResult(ExecutorTemplate.java:72)
... 8 common frames omitted
Caused by: java.lang.OutOfMemoryError: null
at com.alibaba.fastjson2.JSONWriterUTF8.ensureCapacity(JSONWriterUTF8.java:1543)
at com.alibaba.fastjson2.JSONWriterUTF8.writeString(JSONWriterUTF8.java:594)
at com.alibaba.fastjson2.writer.OWG_5_14_FlatMessage.write(Unknown Source)
at com.alibaba.fastjson2.JSON.toJSONBytes(JSON.java:2656)
at com.alibaba.otter.canal.connector.kafka.producer.CanalKafkaProducer.send(CanalKafkaProducer.java:257)
at com.alibaba.otter.canal.connector.kafka.producer.CanalKafkaProducer.lambda$send$0(CanalKafkaProducer.java:158)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
... 3 common frames omitted
我发现有其他伙伴出现同样问题 https://github.com/alibaba/canal/issues/4865，但问题已经关闭，说是在主干已修复，是需要升级到1.1.8版本么？1.1.8正式版预计什么时候发布？谢谢！
2条答案
按热度按时间3bygqnnd1#
@duguwo 4865的抛错是ERROR c.a.o.c.c.rabbitmq.producer.CanalRabbitMQProducer - java.util.concurrent.ExecutionException: java.lang.OutOfMemoryError，和你的CanalKafkaProducer不一致。
kxe2p93d2#
@duguwo 4865的抛错是ERROR c.a.o.c.c.rabbitmq.producer.CanalRabbitMQProducer - java.util.concurrent.ExecutionException: java.lang.OutOfMemoryError，和你的CanalKafkaProducer不一致。
我认为问题应该是一致的，只是使用的消息中间件不一样而已