这是什么报错？Error sync but ACK!

canal v1.1.3 canal adapter v1.1.3 hbase v1.0.3

使用rocketMQ模式, adapter可以接收到消息 INFO c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":[{"s":"122345546786","i":36}],"database":"mytest","destination":"example","es":1561555721000,"groupId":"g1","isDdl":false,"old":[{"s":"546786897893"}],"pkNames":["i"],"sql":"","table":"foo","ts":1561555722080,"type":"UPDATE"}

但是写入不聊hbase, 并且adapter报错: ERROR c.a.o.c.a.launcher.loader.CanalAdapterRocketMQWorker - null Error sync but ACK!

一下是配置文件: canal adapter 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: rocketMQ #tcp # kafka rocketMQ canalServerHost: 127.0.0.1:11111 mqServers: 127.0.0.1:9876 #127.0.0.1:9092 #or rocketmq batchSize: 500 syncBatchSize: 1000 retries: 0 timeout: accessKey: secretKey: srcDataSources: defaultDS: url: jdbc:mysql://127.0.0.1:3306/mytest?useUnicode=true username: root password: root canalAdapters:

instance: example # canal instance Name or mq topic name groups: groupId: g1 outerAdapters: name: logger name: hbase properties: hbase.zookeeper.quorum: 192.168.1.240 hbase.zookeeper.property.clientPort: 2181 zookeeper.znode.parent: /hbase cat conf/hbase/mytest_foo.yml

dataSourceKey: defaultDS destination: example groupId: g1 hbaseMapping: mode: STRING #NATIVE #PHOENIX database: mytest # 数据库名 table: foo # 数据库表名 hbaseTable: MYTEST.FOO # HBase表名 family: CF # 默认统一Family名称 uppercaseQualifier: true # 字段名转大写, 默认为true commitBatch: 1 # 批量提交的大小

原提问者GitHub用户elfc