注:
(1)全量订阅,程序暂时不支持表结构和索引创建,需手动创建表结构 (zcbus-8.1-16-20240530版本已支持)
(2)重新全量订阅前,需手动清理表,程序暂时不支持清理表 — zcbus-8.1-16-20240530版本已支持
(3)需要使用java版本订阅
(4)zcbus-7.6-6-20210510之后版本支持HBASE数据库订阅
(5)需要配置applybykeys,配置主键
(6)程序自动过滤ddl(zcbus-7.6-12-20220314.tar.gz版本支持)
(7)表重建,需要重启client进程,否则程序会按照原来的表结构装载
(8)组合主键存在空值时,程序也会将相应的rowkey置空(zcbus-7.6-12-20220314.tar.gz版本支持)
(9)api长时间插入不返回,需要在/etc/hosts里配置上ip和主机名信息,如:172.17.46.243 hbase-docker
并且hostname一定要与hosts文件里配置的名称一致
(10)需要开放以下端口
hbase.regionserver.port:HBase RegionServer绑定的端口默认60020
hbase.zookeeper.property.clientPort:zookeeper的端口2181
hbase.master.port:Hbase的Master的端口默认60000
(11)zcbus-8.1-16-20240529.tar.gz,修复applybykey设置不生效问题
(12)zcbus-8.1-16-20240530.tar.gz版本支持col_family通道参数(指定列族名称)
- 支持全量ddl,包括:删除、truncate、创建表
- 自动建表格式:
create '订阅指定的库名:订阅指定的表名','列族名字'
说明:列族名默认data,可通过col_family通道参数指定
- 暂不支持增量ddl,会自动过滤
手动校验(zcbus-8.1-16-20240528.tar.gz版本支持):
[oracle@iZ2zeih4ukggzureoarz7pZ jar]$ java -cp zcbusService.jar com.zcbus.connector.HbaseAccess -h
Usage:
-h help
-server user/pwd@ip:port hbase ip port
-table node0.t1 table for insert test, column id,name
手动创建test表(固定字段,id+name):
create 'test:test1','id','name'
检验:
cd zcbus_home/jar
java -cp zcbusService.jar com.zcbus.connector.HbaseAccess -server test/test@172.17.46.243:2181 -table test.test1
查看数据:
scan 'test:test1'