Rocketmq connect同步到mysql 命令显示成功，但是topic无数据怎么排查？
Rocketmq connect同步到mysql 命令显示成功，但是topic无数据怎么排查？日志里没看出问题，只有一个警告
2023-09-02 12:41:17 WARN StateMachineService - no transforms config, {"epoch":1693629314806,"properties":{"connector.class":"org.apache.rocketmq.connect.debezium.mysql.DebeziumMysqlConnector","kafka.transforms.Unwrap.type":"io.debezium.transforms.ExtractNewRecordState","include.schema.changes":"false","kafka.transforms.Unwrap.add.headers":"op,source.db,source.table","connect.topicname":"mis","database.history.skip.unparseable.ddl":"true","value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter","key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter","database.user":"arm","kafka.transforms.Unwrap.delete.handling.mode":"none","database.server.id":"1","database.server.name":"mis","database.port":"3306","max.task":"1","database.history.rocketmq.topic":"db-history-debezium-topic","task.class":"org.apache.rocketmq.connect.debezium.mysql.DebeziumMysqlSource","database.history.name.srv.addr":"xx:9876,xx:9876,xx:9876","database.hostname":"xx","database.connectionTimeZone":"UTC","database.password":"123","database.history.store.only.monitored.tables.ddl":"true","task.id":"0","table.include.list":"mission.test","max.batch.size":"50","kafka.transforms":"Unwrap","database.include.list":"mis","snapshot.mode":"when_needed","database.history":"org.apache.rocketmq.connect.debezium.RocketMqDatabaseHistory"}}
2023-09-02 12:41:17 INFO StateMachineService - [RACE CONDITION] we checked the pending tasks before state turns to PENDING
写回答
-
1、连接mysql数据库查看topic对应的表结构是否存在，是否有数据；
2、在控制台查看connector的运行日志，检查是否有报错信息；
3、检查connector的配置是否正确；
4、检查topic对应的mysql表的权限是否正确，是否允许写入数据；
5、检查mysql数据库的连接是否正常。2023-09-28 10:07:26赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
