1 目标库配置

1.1 订阅选择ROCKETMQ

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

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

然后打开文件查看内容

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）