2022-01-29 15:27:31.623 [pool-4-thread-1] ERROR c.a.o.c.c.pulsarmq.producer.CanalPulsarMQProducer - 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) ~[canal.common-1.1.6-SNAPSHOT.jar:na]
at com.alibaba.otter.canal.connector.pulsarmq.producer.CanalPulsarMQProducer.send(CanalPulsarMQProducer.java:152) ~[na:na]
at com.alibaba.otter.canal.server.CanalMQStarter.worker(CanalMQStarter.java:181) [canal.server-1.1.6-SNAPSHOT.jar:na]
at com.alibaba.otter.canal.server.CanalMQStarter.access$100(CanalMQStarter.java:24) [canal.server-1.1.6-SNAPSHOT.jar:na]
at com.alibaba.otter.canal.server.CanalMQStarter$CanalMQRunnable.run(CanalMQStarter.java:223) [canal.server-1.1.6-SNAPSHOT.jar:na]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_211]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_211]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_211]
Caused by: java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.NullPointerException
at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[na:1.8.0_211]
at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[na:1.8.0_211]
at com.alibaba.otter.canal.common.utils.ExecutorTemplate.waitForResult(ExecutorTemplate.java:72) ~[canal.common-1.1.6-SNAPSHOT.jar:na]
... 7 common frames omitted
Caused by: java.lang.RuntimeException: java.lang.NullPointerException
at com.alibaba.otter.canal.connector.pulsarmq.producer.CanalPulsarMQProducer.lambda$send$0(CanalPulsarMQProducer.java:147) ~[na:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_211]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_211]
... 3 common frames omitted
Caused by: java.lang.NullPointerException: null
配置 canal.properties如下:
pulsar配置已经添加如下：
请教是哪里的问题吗？
2条答案
按热度按时间bvuwiixz1#
日志不太全，看不到NPE具体的代码栈
14ifxucb2#
at com.alibaba.otter.canal.server.CanalMQStarter.access$500(CanalMQStarter.java:23) [canal.server-1.1.4.jar:na]
at com.alibaba.otter.canal.server.CanalMQStarter$CanalMQRunnable.run(CanalMQStarter.java:225) [canal.server-1.1.4.jar:na]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
2022-05-25 10:35:22.079 [pool-4-thread-2] ERROR com.alibaba.otter.canal.server.CanalMQStarter - process error!
java.lang.NullPointerException: null
at com.alibaba.otter.canal.server.CanalMQStarter.worker(CanalMQStarter.java:157) [canal.server-1.1.4.jar:na]
at com.alibaba.otter.canal.server.CanalMQStarter.access$500(CanalMQStarter.java:23) [canal.server-1.1.4.jar:na]
at com.alibaba.otter.canal.server.CanalMQStarter$CanalMQRunnable.run(CanalMQStarter.java:225) [canal.server-1.1.4.jar:na]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
2022-05-25 10:35:22.079 [pool-4-thread-2] ERROR com.alibaba.otter.canal.server.CanalMQStarter - process error!
我也遇到这个问题了，麻烦帮忙看一下