错误信息为:Load canal adapter:es7 failed .Failed to bind properties under ‘es-mapping’ to com.alibaba.otter.canal.client.adapter.es.core.config.ESSyncConfig$ESMapping at canal.client.adapter.es7x.es7xAdapter.init(ES7xAdapter.java:54)

adapter\conf\es7下有test.yml文件，内容如下：
dataSourceKey: defaultDS
destination: example
groupId: g1
esMapping:
_index: customer
_id: id
sql: "select id, name from test"
commitBatch: 3000

application.yml配置如下：
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: -1
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:
# kafka consumer
kafka.bootstrap.servers: 127.0.0.1:9092
kafka.enable.auto.commit: false
kafka.auto.commit.interval.ms: 1000
kafka.auto.offset.reset: latest
kafka.request.timeout.ms: 40000
kafka.session.timeout.ms: 30000
kafka.isolation.level: read_committed
kafka.max.poll.records: 1000
# rocketMQ consumer
rocketmq.namespace:
rocketmq.namesrv.addr: 127.0.0.1:9876
rocketmq.batch.size: 1000
rocketmq.enable.message.trace: false
rocketmq.customized.trace.topic:
rocketmq.access.channel:
rocketmq.subscribe.filter:
# rabbitMQ consumer
rabbitmq.host:
rabbitmq.virtual.host:
rabbitmq.username:
rabbitmq.password:
rabbitmq.resource.ownerId:

srcDataSources:
defaultDS:
url: jdbc:mysql://127.0.0.1:3306/mytest?useUnicode=true
username: root
password: 121212
canalAdapters:

• instance: example # canal instance Name or mq topic name
  groups:
  • groupId: g1
    outerAdapters:
    • name: logger

      - name: rdb

      key: mysql1

      properties:

      jdbc.driverClassName: com.mysql.jdbc.Driver

      jdbc.url: jdbc:mysql://127.0.0.1:3306/mytest2?useUnicode=true

      jdbc.username: root

      jdbc.password: 121212

      druid.stat.enable: false

      druid.stat.slowSqlMillis: 1000

      - name: rdb

      key: oracle1

      properties:

      jdbc.driverClassName: oracle.jdbc.OracleDriver

      jdbc.url: jdbc:oracle:thin:@localhost:49161:XE

      jdbc.username: mytest

      jdbc.password: m121212

      - name: rdb

      key: postgres1

      properties:

      jdbc.driverClassName: org.postgresql.Driver

      jdbc.url: jdbc:postgresql://localhost:5432/postgres

      jdbc.username: postgres

      jdbc.password: 121212

      threads: 1

      commitSize: 3000

      - name: hbase

      properties:

      hbase.zookeeper.quorum: 127.0.0.1

      hbase.zookeeper.property.clientPort: 2181

      zookeeper.znode.parent: /hbase

    • name: es
      hosts: 127.0.0.1:9200 # 127.0.0.1:9200 for rest mode
      properties:
      mode: rest# or rest

      # security.auth: test:123456 # only used for rest mode

      cluster.name: elasticsearch

      - name: kudu

      key: kudu

      properties:

      kudu.master.address: 127.0.0.1 # ',' split multi address

      - name: phoenix

      key: phoenix

      properties:

      jdbc.driverClassName: org.apache.phoenix.jdbc.PhoenixDriver

      jdbc.url: jdbc:phoenix:127.0.0.1:2181:/hbase/db

      jdbc.username:

      jdbc.password:

deployer\conf\example\instance.properties配置如下：

#

mysql serverId , v1.0.26+ will autoGen

canal.instance.mysql.slaveId=0

enable gtid use true/false

canal.instance.gtidon=false

position info

canal.instance.master.address=127.0.0.1:3306
canal.instance.master.journal.name=
canal.instance.master.position=
canal.instance.master.timestamp=
canal.instance.master.gtid=

rds oss binlog

canal.instance.rds.accesskey=
canal.instance.rds.secretkey=
canal.instance.rds.instanceId=

table meta tsdb info

canal.instance.tsdb.enable=true

canal.instance.tsdb.url=jdbc:mysql://127.0.0.1:3306/canal_tsdb

canal.instance.tsdb.dbUsername=canal

canal.instance.tsdb.dbPassword=canal

canal.instance.standby.address =

canal.instance.standby.journal.name =

canal.instance.standby.position =

canal.instance.standby.timestamp =

canal.instance.standby.gtid=

username/password

canal.instance.dbUsername=canal
canal.instance.dbPassword=canal
canal.instance.connectionCharset = UTF-8

enable druid Decrypt database password

canal.instance.enableDruid=false

canal.instance.pwdPublicKey=MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBALK4BUxdDltRRE5/zXpVEVPUgunvscYFtEip3pmLlhrWpacX7y7GCMo2/JM6LeHmiiNdH1FWgGCpUfircSwlWKUCAwEAAQ==

table regex

canal.instance.filter.regex=mytest.test

table black regex

canal.instance.filter.black.regex=mysql\.slave_.*

table field filter(format: schema1.tableName1:field1/field2,schema2.tableName2:field1/field2)

canal.instance.filter.field=test1.t_product:id/subject/keywords,test2.t_company:id/name/contact/ch

table field black filter(format: schema1.tableName1:field1/field2,schema2.tableName2:field1/field2)

canal.instance.filter.black.field=test1.t_product:subject/product_image,test2.t_company:id/name/contact/ch

mq config

canal.mq.topic=example

dynamic topic route by schema or table regex

canal.mq.dynamicTopic=mytest1.user,topic2:mytest2\..,.\..*

canal.mq.partition=0

hash partition config

canal.mq.enableDynamicQueuePartition=false

canal.mq.partitionsNum=3

canal.mq.dynamicTopicPartitionNum=test.*:4,mycanal:6

canal.mq.partitionHash=test.table:id^name,.\..

#

multi stream for polardbx

canal.instance.multi.stream.on=false

#