mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
Updated Sync HBase (markdown)
@@ -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
|
||||
```
|
||||
|
||||
Reference in New Issue
Block a user