在数据库里插入数据,同步ES失败,刚接触,日志提示比较简单,不明白是什么问题。 log 日志: Outer adapter write failed
配置文件:
application.yml
server: port: 8081 logging: level: org.springframework: WARN com.alibaba.otter.canal.client.adapter.hbase: DEBUG com.alibaba.otter.canal.client.adapter.es: DEBUG com.alibaba.otter.canal.client.adapter.rdb: DEBUG spring: jackson: date-format: yyyy-MM-dd HH:mm:ss time-zone: GMT+8 default-property-inclusion: non_null
canal.conf: canalServerHost: 127.0.0.1:11111 batchSize: 500 syncBatchSize: 1000 retries: 0 timeout: accessKey: secretKey: mode: tcp # kafka rocketMQ srcDataSources: defaultDS: url: jdbc:mysql://127.0.0.1:3307/testdb?useUnicode=true username: root password: 123456 canalAdapters: - instance: example # canal instance Name or mq topic name groups: - groupId: g1 outerAdapters: - name: logger - name: es hosts: 127.0.0.1:9300 properties: cluster.name: elasticsearch_reid
es:
dataSourceKey: defaultDS destination: example esMapping: _index: testdb _type: test _id: id sql: "select id, content from test" commitBatch: 3000
ES 索引结构:
{ "settings": { "number_of_replicas": 0 }, "mappings": { "test": { "properties": { "content": { "type": "text", "analyzer": "ik_smart", "search_analyzer": "ik_smart" } } } } }
原提问者GitHub用户linyongfu2013
从日志信息来看,提示是“Outer adapter write failed”,即外部适配器写入失败。这可能是由于一些错误导致的,比如网络连接问题、权限问题、数据格式问题等等。建议在具体排查时,根据日志信息和错误提示,逐步排除可能引起问题的因素,定位具体的问题所在。同时也可以查看ES的错误日志,看是否有相关的报错信息。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。