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
Rocketmq connect同步到mysql 命令显示成功,但是topic无数据怎么排查?[阿里云消息队列MQ]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!