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数据库的连接是否正常。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/