canal-adapter ERROR c.a.otter.canal.adapter.launcher.loader.AdapterProcessor - process error! Connection refused: connect

oyt4ldly  于 4个月前  发布在  其他
关注(0)|答案(6)|浏览(62)

canal-adapter 1.1.6
es 7.4.2

canal-adapter 日志一直报这个错

2023-02-16 16:59:10.759 [main] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterService - ## syncSwitch refreshed. 2023-02-16 16:59:10.759 [main] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterService - ## start the canal client adapters. 2023-02-16 16:59:10.763 [main] INFO c.a.otter.canal.client.adapter.support.ExtensionLoader - extension classpath dir: D:\canal1.1.6\canal.adapter-1.1.6\plugin 2023-02-16 16:59:10.804 [main] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterLoader - Load canal adapter: logger succeed 2023-02-16 16:59:10.977 [main] INFO c.a.o.c.client.adapter.es.core.config.ESSyncConfigLoader - ## Start loading es mapping config ... 2023-02-16 16:59:11.039 [main] INFO c.a.o.c.client.adapter.es.core.config.ESSyncConfigLoader - ## ES mapping config loaded 2023-02-16 16:59:11.397 [main] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterLoader - Load canal adapter: es7 succeed 2023-02-16 16:59:11.404 [main] INFO c.alibaba.otter.canal.connector.core.spi.ExtensionLoader - extension classpath dir: D:\canal1.1.6\canal.adapter-1.1.6\plugin 2023-02-16 16:59:11.425 [main] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterLoader - Start adapter for canal-client mq topic: example-g1 succeed 2023-02-16 16:59:11.426 [main] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterService - ## the canal client adapters are running now ...... 2023-02-16 16:59:11.426 [Thread-4] INFO c.a.otter.canal.adapter.launcher.loader.AdapterProcessor - =============> Start to connect destination: example <============= 2023-02-16 16:59:11.432 [main] INFO org.apache.coyote.http11.Http11NioProtocol - Starting ProtocolHandler ["http-nio-8081"] 2023-02-16 16:59:11.435 [main] INFO org.apache.tomcat.util.net.NioSelectorPool - Using a shared selector for servlet write/read 2023-02-16 16:59:11.449 [main] INFO o.s.boot.web.embedded.tomcat.TomcatWebServer - Tomcat started on port(s): 8081 (http) with context path '' 2023-02-16 16:59:11.451 [main] INFO c.a.otter.canal.adapter.launcher.CanalAdapterApplication - Started CanalAdapterApplication in 6.107 seconds (JVM running for 7.081) 2023-02-16 16:59:13.463 [Thread-4] ERROR c.a.otter.canal.adapter.launcher.loader.AdapterProcessor - process error! com.alibaba.otter.canal.protocol.exception.CanalClientException: java.net.ConnectException: Connection refused: connect at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.doConnect(SimpleCanalConnector.java:200) ~[na:na] at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.connect(SimpleCanalConnector.java:116) ~[na:na] at com.alibaba.otter.canal.connector.tcp.consumer.CanalTCPConsumer.connect(CanalTCPConsumer.java:63) ~[na:na] at com.alibaba.otter.canal.adapter.launcher.loader.AdapterProcessor.process(AdapterProcessor.java:185) ~[client-adapter.launcher-1.1.6.jar:na] at java.lang.Thread.run(Unknown Source) ~[na:1.8.0_121] Caused by: java.net.ConnectException: Connection refused: connect at sun.nio.ch.Net.connect0(Native Method) ~[na:1.8.0_121] at sun.nio.ch.Net.connect(Unknown Source) ~[na:1.8.0_121] at sun.nio.ch.Net.connect(Unknown Source) ~[na:1.8.0_121] at sun.nio.ch.SocketChannelImpl.connect(Unknown Source) ~[na:1.8.0_121] at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.doConnect(SimpleCanalConnector.java:152) ~[na:na] ... 4 common frames omitted 2023-02-16 16:59:14.474 [Thread-4] INFO c.a.otter.canal.adapter.launcher.loader.AdapterProcessor - =============> Start to connect destination: example <============= 2023-02-16 16:59:16.493 [Thread-4] ERROR c.a.otter.canal.adapter.launcher.loader.AdapterProcessor - process error! com.alibaba.otter.canal.protocol.exception.CanalClientException: java.net.ConnectException: Connection refused: connect at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.doConnect(SimpleCanalConnector.java:200) ~[na:na] at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.connect(SimpleCanalConnector.java:116) ~[na:na] at com.alibaba.otter.canal.connector.tcp.consumer.CanalTCPConsumer.connect(CanalTCPConsumer.java:63) ~[na:na] at com.alibaba.otter.canal.adapter.launcher.loader.AdapterProcessor.process(AdapterProcessor.java:185) ~[client-adapter.launcher-1.1.6.jar:na] at java.lang.Thread.run(Unknown Source) ~[na:1.8.0_121] Caused by: java.net.ConnectException: Connection refused: connect at sun.nio.ch.Net.connect0(Native Method) ~[na:1.8.0_121] at sun.nio.ch.Net.connect(Unknown Source) ~[na:1.8.0_121] at sun.nio.ch.Net.connect(Unknown Source) ~[na:1.8.0_121] at sun.nio.ch.SocketChannelImpl.connect(Unknown Source) ~[na:1.8.0_121] at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.doConnect(SimpleCanalConnector.java:152) ~[na:na] ... 4 common frames omitted

canal

6条答案

按热度按时间
hivapdat

hivapdat1#

`server:
port: 8081
spring:
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
default-property-inclusion: non_null

canal.conf:
mode: tcp #tcp kafka rocketMQ rabbitMQ
flatMessage: true
zookeeperHosts:
syncBatchSize: 1000
retries: 0
timeout:
accessKey:
secretKey:
consumerProperties:

canal tcp consumer

canal.tcp.server.host: 127.0.0.1:11111
canal.tcp.zookeeper.hosts:
canal.tcp.batch.size: 500
canal.tcp.username:
canal.tcp.password:
srcDataSources:
defaultDS:
url: jdbc:mysql://写的正确的?useUnicode=true
username: root
password: 写的正确的
canalAdapters:

  • instance: example # canal instance Name or mq topic name
    groups:

  • groupId: g1
    outerAdapters:

  • name: logger

  • name: es7
    hosts: http://127.0.0.1:9200 # 127.0.0.1:9200 for rest mode
    properties:
    mode: rest #transport # or rest
    cluster.name: elasticsearch
    security.auth: elastic: elastic #es，没有设置密码`

赞(0）分享  回复(0）举报  4个月前
jfewjypa

jfewjypa2#

canal service 有启动吗

赞(0）分享  回复(0）举报  4个月前
b1zrtrql

b1zrtrql3#

启动好了   ，适配器也启动好了   蔡盛 @***.  …

------------------ 原始邮件 ------------------ 发件人: ***@***.***>; 发送时间: 2023年2月25日(星期六) 上午9:42 收件人: ***@***.***>; 抄送: ***@***.***>; ***@***.***>; 主题: Re: [alibaba/canal] canal-adapter ERROR c.a.otter.canal.adapter.launcher.loader.AdapterProcessor - process error! Connection refused: connect (Issue #4607) canal service 有启动吗 — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: ***@***.***>

赞(0）分享  回复(0）举报  4个月前
2g32fytz

2g32fytz4#

请问你解决了吗 我也遇到这个问题

赞(0）分享  回复(0）举报  4个月前
i7uaboj4

i7uaboj45#

解决了   蔡盛 @***.  …

------------------ 原始邮件 ------------------ 发件人: ***@***.***>; 发送时间: 2023年7月11日(星期二) 下午2:04 收件人: ***@***.***>; 抄送: ***@***.***>; ***@***.***>; 主题: Re: [alibaba/canal] canal-adapter ERROR c.a.otter.canal.adapter.launcher.loader.AdapterProcessor - process error! Connection refused: connect (Issue #4607) 请问你解决了吗 我也遇到这个问题 — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: ***@***.***>

赞(0）分享  回复(0）举报  4个月前
gg58donl

gg58donl6#

怎么解决的？

赞(0）分享  回复(0）举报  4个月前
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com