diff --git a/Sync-HBase.md b/Sync-HBase.md index 644f749..7b2705b 100644 --- a/Sync-HBase.md +++ b/Sync-HBase.md @@ -4,32 +4,26 @@ canal 1.1.1版本之后, 内置增加客户端数据同步功能, Client适配 # HBase适配器 ## 1. 修改启动器配置: application.yml ``` -server: - port: 8081 -logging: - level: - com.alibaba.otter.canal.client.adapter.hbase: 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 # 配置具体的canal server地址 - flatMessage: true + canalServerHost: 127.0.0.1:11111 + batchSize: 500 + syncBatchSize: 1000 + retries: 0 + timeout: + mode: tcp # kafka rocketMQ srcDataSources: defaultDS: url: jdbc:mysql://127.0.0.1:3306/mytest?useUnicode=true username: root password: 121212 - canalInstances: - - instance: example - adapterGroups: - - outAdapters: + canalAdapters: + - instance: example # canal instance Name or mq topic name + groups: + - groupId: g1 + outerAdapters: - name: hbase properties: - hbase.zookeeper.quorum: slave1 + hbase.zookeeper.quorum: 127.0.0.1 hbase.zookeeper.property.clientPort: 2181 zookeeper.znode.parent: /hbase ```