开发者社区 > 云原生 > 云消息队列 > 正文

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

展开
收起
2401。 2023-09-02 16:30:30 166 0
1 条回答
写回答
取消 提交回答
  • 1、连接mysql数据库查看topic对应的表结构是否存在,是否有数据;
    2、在控制台查看connector的运行日志,检查是否有报错信息;
    3、检查connector的配置是否正确;
    4、检查topic对应的mysql表的权限是否正确,是否允许写入数据;
    5、检查mysql数据库的连接是否正常。

    2023-09-28 10:07:26
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 热门讨论

    热门文章

    相关电子书

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载

    相关镜像