ROCKETMQ

注：
（1）使用C程序加载，java程序暂不支持 –zcbus-7.6-9-20210630.tar.gz；

（2）指定topic：批量保存库名，rocketmq如果设置了自动创建topic，指定的topic无需手动创建；

（3）lib做了更新：librocketmq.so
cp /code/librocketmq.so /busdata/zl/zcbus/2.0.1/lib/zc_lib/
（4）json格式-output_data_format=0：
全量：

[{"op_time":"2021-07-01 11:04:55","database_name":"ZFL","table_name":"TEST","optype":"ddl","values":"create table "ZFL"."TEST"(
"ID" NUMBER(*,0) NOT NULL,
"NAME" VARCHAR2(100),
CONSTRAINT "SYS_C00180409" PRIMARY KEY("ID")
);"}]
[{"op_time":"2021-07-01 11:04:56","database_name":"ZFL","table_name":"TEST","optype":"insert","values":{"ID":"1","NAME":"sss"}}]

增量：

[{"op_time":"2021-07-01 11:04:37","database_name":"ZFL","table_name":"TEST","optype":"insert","values":{"ID":"2","NAME":"sss"}}]
[{"op_time":"2021-07-01 11:10:18","database_name":"ZFL","table_name":"TEST","optype":"update","before":{"ID":"1","NAME":"sss"},"after":{"NAME":"sssssssss"}},{"op_time":"2021-07-01 11:10:18","database_name":"ZFL","table_name":"TEST","optype":"update","before":{"ID":"2","NAME":"sss"},"after":{"NAME":"sssssssss"}}]
[{"op_time":"2021-07-01 11:18:39","database_name":"ZFL","table_name":"TEST","optype":"delete","values":{"ID":"2","NAME":"sssssssss"}}]

（4）sql格式-output_data_format=1：
全量：

create table "ZFL"."TEST"(
"ID" NUMBER(*,0) NOT NULL,
"NAME" VARCHAR2(100),
CONSTRAINT "SYS_C00180409" PRIMARY KEY("ID")
);
insert into ZFL.TEST(ID,NAME) values(1,'sss');

增量：

insert into ZFL.TEST(ID,NAME) values(2,'sss');
update ZFL.TEST set NAME='sssssssss' where ID=1 and NAME='sss';
update ZFL.TEST set NAME='sssssssss' where ID=2 and NAME='sss';
delete from ZFL.TEST where ID=2 and NAME='sssssssss';
alter table test  add test_lob blob;

（5）blob测试-sql模式：
oracle测试语句：

alter table test  add test_lob blob;
insert into test  values(66,'test测试',rawtohex('里面放需要增加的BLOB'));
update test set test_lob=rawtohex('里面放需要增加的BLOB') where id=66;
delete from test where id=66;

rocketmq生成的消息：

alter table test  add test_lob blob;;
insert into ZFL.TEST(ID,NAME,TEST_LOB) values(66,'test测试',0xc0efc3e6b7c5d0e8d2aad4f6bcd3b5c4424c4f42);
update ZFL.TEST set ID=66,NAME='test测试',TEST_LOB=0xc0efc3e6b7c5d0e8d2aad4f6bcd3b5c4424c4f42 where ID=66 and NAME='test测试';
delete from ZFL.TEST where ID=66 and NAME='test测试' and TEST_LOB is null;

web上查看消息

选择topic—>指定时间段—>点击搜索按钮—>点击详细消息按钮