1 目标库配置

1.1 订阅选择ROCKETMQ

1.1.1 编辑数据库时，可修改进入ROCKETMQ数据格式，默认为JSON

zcbus-8.3-16-20250124.tar.gz版本支持java模式

1.1.2 开启全量订阅

1.2 查看订阅到的文件数据

1.2.1 订阅json格式重定向生成topic_json.txt文件

[root@node bin]# sh mqadmin printMsg -t TopicJSON -n 192.168.0.66:9876 > topic_json.txt
OpenJDK 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
OpenJDK 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0

然后打开文件查看内容

1.2.2 订阅sql格式重定向生成topic_sql.txt文件

[root@node bin]# sh mqadmin printMsg -t TopicSQL -n 192.168.0.66:9876 > topic_sql.txt
OpenJDK 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
OpenJDK 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0

然后打开文件查看内容

1.2.3 生产消费测试工具

zcbus-8.3-16-20250126.tar.gz版本支持

[oracle@iZ2zeih4ukggzureoarz7pZ jar]$ java -cp zcbusService.jar com.zcbus.connector.RocketmqAccess -h
Usage: 
       -h                              help
       -host_list                      like 47.93.83.53:9876
       -topic                          topic name
       -send_len                       send data length, default 100
       -send_times                     send data times
       -consume                        consume topic
生产示例：
java -cp zcbusService.jar com.zcbus.connector.RocketmqAccess -host_list 172.17.104.186:9876 -topic test222 -send_times 2 -send_len 500
消费示例：
nohup java -cp zcbusService.jar com.zcbus.connector.RocketmqAccess -host_list 172.17.104.186:9876 -topic test112233     -consume > 1.log 2>&1 &

2 补充说明

2.1 配置目标数据库参数列表

问题记录

报错

ZCBUS-4600: rocketmq SendMessageSync, msg: No route info of this topic:

排查原因：

• Broker禁止自动创建Topic，且用户没有通过手工方式创建Topic
• Broker没有正确连接到Name Server
• Producer没有正确连接到Name Server
• zcbus通道参数max_message_size和rocketmq-broker服务的maxMessageSize参数不一致（rocketmq-broker服务的maxMessageSize参数值默认4M，zcbus通道max_message_size参数值默认5M）