Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-8730

Debezium Server 3.0.7 Sync mongodb receive the data is string "default"

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Not a Bug
    • Icon: Major Major
    • None
    • 3.0.7.Final
    • debezium-server
    • None
    • False
    • Hide

      None

      Show
      None
    • False
    • Hide
      configure option
      debezium.source.tombstones.on.delete=false
      Show
      configure option debezium.source.tombstones.on.delete=false
    • Critical

      In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.

      Bug report

      For bug reports, provide this information, please:

      What Debezium connector do you use and what version?

      Debezium Server 3.0.7

      Mongodb

      What is the connector configuration?

       

      // code placeholder
debezium.source.name=wechat_pro
debezium.source.connector.class=io.debezium.connector.mongodb.MongoDbConnector
debezium.source.mongodb.connection.string=mongodb://127.0.0.1:3717,127.0.0.3:3717/admin?replicaSet=mycluster
debezium.source.mongodb.name=wechat
debezium.source.mongodb.user=debezium
debezium.source.mongodb.password=facai@188
debezium.source.mongodb.authsource=admin
debezium.source.mongodb.ssl.enabled=false
debezium.source.mongodb.connection.timeout.ms=30000
debezium.source.mongodb.socket.timeout.ms=30000
debezium.source.database.include.list=mydb
debezium.source.collection.include.list=mydb.orderly,mydb.material
debezium.source.poll.interval.ms=500
debezium.source.batch.size=1000
debezium.source.max.queue.size=8192
debezium.source.topic.prefix=robot
debezium.source.capture.mode=change_streams_update_full
debezium.source.capture.scope=database
debezium.source.capture.target=mydb
debezium.source.skipped.operations=t
debezium.source.snapshot.mode=no_data
debezium.source.snapshot.max.threads=4

debezium.source.key.converter=org.apache.kafka.connect.json.JsonConverter
debezium.source.key.converter.schemas.enable=false
debezium.source.value.converter=org.apache.kafka.connect.json.JsonConverter
debezium.source.value.converter.schemas.enable=false
debezium.source.decimal.handling.mode=string

# offset file
debezium.source.offset.storage.file.filename=./data/mongodb.data
#1s
debezium.source.offset.flush.interval.ms=1000

       

       

      What is the captured database version and mode of deployment?

      (E.g. on-premises, with a specific cloud provider, etc.)

      mongodb7.0

      What behavior do you expect?

       

      What behavior do you see?

      receive the data is the string "default" ,rather than the document json data

      Do you see the same behaviour using the latest released Debezium version?

      Debezium Server 3.0.7 

      Do you have the connector logs, ideally from start till finish?

      (You might be asked later to provide DEBUG/TRACE level log)

      no error log  here is 

       

      // code placeholder
2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,045 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,045 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,046 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) polling records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,046 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,234 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 321.598854 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16942 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC2761000000CC2B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C696E736572740046646F63756D656E744B65790046645F6964006467BC27616DBD8CD539C8AB92000004"}, "operationType": "insert", "clusterTime": {"$timestamp": {"t": 1740384097, "i": 204}}, "wallTime": {"$date": "2025-02-24T08:01:37.23Z"}, "fullDocument": {"_id": {"$oid": "67bc27616dbd8cd539c8ab92"}, "platform": 1, "request": {"status": "211", "msg": "GIF消息回调", "data": {"msgContent": "<msg><emoji fromusername=\"wxid_znc2qvh26np321\" tousername=\"22149082331@chatroom\" type=\"2\" idbuffer=\"media:0_0\" md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" len=\"221429\" productid=\"\" androidmd5=\"bc6e46b075c99b551b78600e9c4dd3a6\" androidlen=\"221429\" s60v3md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v3len=\"221429\" s60v5md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v5len=\"221429\" cdnurl=\"http://vweixinf.tc.qq.com/110/20401/stodownload?m=bc6e46b075c99b551b78600e9c4 ...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,235 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,235 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,235 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,235 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,235 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16943 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384097, "i": 206}}, "signature": {"hash": {"$binary": {"base64": "o44gyPI0Kv++BlcwhqBhb2b9tZo=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,286 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 51.035289 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16943 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC2761000000D52B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C7570646174650046646F63756D656E744B65790046645F6964006467BC27616DBD8CD539C8AB92000004"}, "operationType": "update", "clusterTime": {"$timestamp": {"t": 1740384097, "i": 213}}, "wallTime": {"$date": "2025-02-24T08:01:37.284Z"}, "fullDocument": {"_id": {"$oid": "67bc27616dbd8cd539c8ab92"}, "platform": 1, "request": {"status": "211", "msg": "GIF消息回调", "data": {"msgContent": "<msg><emoji fromusername=\"wxid_znc2qvh26np321\" tousername=\"22149082331@chatroom\" type=\"2\" idbuffer=\"media:0_0\" md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" len=\"221429\" productid=\"\" androidmd5=\"bc6e46b075c99b551b78600e9c4dd3a6\" androidlen=\"221429\" s60v3md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v3len=\"221429\" s60v5md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v5len=\"221429\" cdnurl=\"http://vweixinf.tc.qq.com/110/20401/stodownload?m=bc6e46b075c99b551b78600e9c ...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,286 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,286 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,287 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,287 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,287 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16944 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384097, "i": 213}}, "signature": {"hash": {"$binary": {"base64": "o44gyPI0Kv++BlcwhqBhb2b9tZo=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,487 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 199.753499 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16944 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC2761000001442B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C7570646174650046646F63756D656E744B65790046645F6964006467BC27616DBD8CD539C8AB92000004"}, "operationType": "update", "clusterTime": {"$timestamp": {"t": 1740384097, "i": 324}}, "wallTime": {"$date": "2025-02-24T08:01:37.484Z"}, "fullDocument": {"_id": {"$oid": "67bc27616dbd8cd539c8ab92"}, "platform": 1, "request": {"status": "211", "msg": "GIF消息回调", "data": {"msgContent": "<msg><emoji fromusername=\"wxid_znc2qvh26np321\" tousername=\"22149082331@chatroom\" type=\"2\" idbuffer=\"media:0_0\" md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" len=\"221429\" productid=\"\" androidmd5=\"bc6e46b075c99b551b78600e9c4dd3a6\" androidlen=\"221429\" s60v3md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v3len=\"221429\" s60v5md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v5len=\"221429\" cdnurl=\"http://vweixinf.tc.qq.com/110/20401/stodownload?m=bc6e46b075c99b551b78600e9c ...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,487 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,487 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,487 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,487 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,487 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16945 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384097, "i": 324}}, "signature": {"hash": {"$binary": {"base64": "o44gyPI0Kv++BlcwhqBhb2b9tZo=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,546 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,547 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,547 DEBUG [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Sending 3 records to topic robot.robot.orderly2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,547 DEBUG [io.deb.emb.asy.ParallelSmtAndConvertBatchProcessor] (pool-10-thread-1) Thread pool-10-thread-1 is submitting 3 records for processing.2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,550 DEBUG [org.apa.kaf.con.sto.OffsetStorageWriter] (pool-10-thread-1) Submitting 1 entries to backing store. The offsets are: {{server_id=robot}={sec=1740384097, ord=324, resume_token=zQAAAAJfZGF0YQC9AAAAODI2N0JDMjc2MTAwMDAwMTQ0MkIwNDJDMDEwMDI5NkU1QTEwMDQ0QjFDRDcyMzkyOUQ0MEI4QUFEQTY0RDUyNDJFMTE4RDQ2M0M2RjcwNjU3MjYxNzQ2OTZGNkU1NDc5NzA2NTAwM0M3NTcwNjQ2MTc0NjUwMDQ2NjQ2RjYzNzU2RDY1NkU3NDRCNjU3OTAwNDY2NDVGNjk2NDAwNjQ2N0JDMjc2MTZEQkQ4Q0Q1MzlDOEFCOTIwMDAwMDQAAA==}}2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,550 DEBUG [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Committing offset '{server_id=robot}' for partition '{sec=1740384097, ord=324, resume_token=zQAAAAJfZGF0YQC9AAAAODI2N0JDMjc2MTAwMDAwMTQ0MkIwNDJDMDEwMDI5NkU1QTEwMDQ0QjFDRDcyMzkyOUQ0MEI4QUFEQTY0RDUyNDJFMTE4RDQ2M0M2RjcwNjU3MjYxNzQ2OTZGNkU1NDc5NzA2NTAwM0M3NTcwNjQ2MTc0NjUwMDQ2NjQ2RjYzNzU2RDY1NkU3NDRCNjU3OTAwNDY2NDVGNjk2NDAwNjQ2N0JDMjc2MTZEQkQ4Q0Q1MzlDOEFCOTIwMDAwMDQAAA==}'2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,550 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) polling records...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,550 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,777 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 290.083848 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16945 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC2761000006562B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C7570646174650046646F63756D656E744B65790046645F6964006467BC27616DBD8CD539C8AB92000004"}, "operationType": "update", "clusterTime": {"$timestamp": {"t": 1740384097, "i": 1622}}, "wallTime": {"$date": "2025-02-24T08:01:37.773Z"}, "fullDocument": {"_id": {"$oid": "67bc27616dbd8cd539c8ab92"}, "platform": 1, "request": {"status": "211", "msg": "GIF消息回调", "data": {"msgContent": "<msg><emoji fromusername=\"wxid_znc2qvh26np321\" tousername=\"22149082331@chatroom\" type=\"2\" idbuffer=\"media:0_0\" md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" len=\"221429\" productid=\"\" androidmd5=\"bc6e46b075c99b551b78600e9c4dd3a6\" androidlen=\"221429\" s60v3md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v3len=\"221429\" s60v5md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v5len=\"221429\" cdnurl=\"http://vweixinf.tc.qq.com/110/20401/stodownload?m=bc6e46b075c99b551b78600e9 ...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,778 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,778 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,778 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,778 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,778 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16946 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384097, "i": 1633}}, "signature": {"hash": {"$binary": {"base64": "o44gyPI0Kv++BlcwhqBhb2b9tZo=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,847 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 68.435599 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16946 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC2761000007452B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C7570646174650046646F63756D656E744B65790046645F6964006467BC27616DBD8CD539C8AB92000004"}, "operationType": "update", "clusterTime": {"$timestamp": {"t": 1740384097, "i": 1861}}, "wallTime": {"$date": "2025-02-24T08:01:37.843Z"}, "fullDocument": {"_id": {"$oid": "67bc27616dbd8cd539c8ab92"}, "platform": 1, "request": {"status": "211", "msg": "GIF消息回调", "data": {"msgContent": "<msg><emoji fromusername=\"wxid_znc2qvh26np321\" tousername=\"22149082331@chatroom\" type=\"2\" idbuffer=\"media:0_0\" md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" len=\"221429\" productid=\"\" androidmd5=\"bc6e46b075c99b551b78600e9c4dd3a6\" androidlen=\"221429\" s60v3md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v3len=\"221429\" s60v5md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v5len=\"221429\" cdnurl=\"http://vweixinf.tc.qq.com/110/20401/stodownload?m=bc6e46b075c99b551b78600e9 ...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,847 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,847 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,847 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,847 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,847 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16947 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384097, "i": 1870}}, "signature": {"hash": {"$binary": {"base64": "o44gyPI0Kv++BlcwhqBhb2b9tZo=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,849 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 1.624513 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16947 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC27610000074D2B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C7570646174650046646F63756D656E744B65790046645F6964006467BC27616DBD8CD539C8AB92000004"}, "operationType": "update", "clusterTime": {"$timestamp": {"t": 1740384097, "i": 1869}}, "wallTime": {"$date": "2025-02-24T08:01:37.845Z"}, "fullDocument": {"_id": {"$oid": "67bc27616dbd8cd539c8ab92"}, "platform": 1, "request": {"status": "211", "msg": "GIF消息回调", "data": {"msgContent": "<msg><emoji fromusername=\"wxid_znc2qvh26np321\" tousername=\"22149082331@chatroom\" type=\"2\" idbuffer=\"media:0_0\" md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" len=\"221429\" productid=\"\" androidmd5=\"bc6e46b075c99b551b78600e9c4dd3a6\" androidlen=\"221429\" s60v3md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v3len=\"221429\" s60v5md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v5len=\"221429\" cdnurl=\"http://vweixinf.tc.qq.com/110/20401/stodownload?m=bc6e46b075c99b551b78600e9 ...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,849 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,849 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,849 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,849 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,849 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16948 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384097, "i": 1875}}, "signature": {"hash": {"$binary": {"base64": "o44gyPI0Kv++BlcwhqBhb2b9tZo=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,852 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 3.047533 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16948 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC2761000007562B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C7570646174650046646F63756D656E744B65790046645F6964006467BC27616DBD8CD539C8AB92000004"}, "operationType": "update", "clusterTime": {"$timestamp": {"t": 1740384097, "i": 1878}}, "wallTime": {"$date": "2025-02-24T08:01:37.849Z"}, "fullDocument": {"_id": {"$oid": "67bc27616dbd8cd539c8ab92"}, "platform": 1, "request": {"status": "211", "msg": "GIF消息回调", "data": {"msgContent": "<msg><emoji fromusername=\"wxid_znc2qvh26np321\" tousername=\"22149082331@chatroom\" type=\"2\" idbuffer=\"media:0_0\" md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" len=\"221429\" productid=\"\" androidmd5=\"bc6e46b075c99b551b78600e9c4dd3a6\" androidlen=\"221429\" s60v3md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v3len=\"221429\" s60v5md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v5len=\"221429\" cdnurl=\"http://vweixinf.tc.qq.com/110/20401/stodownload?m=bc6e46b075c99b551b78600e9 ...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,853 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 2 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,853 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,853 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,853 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,853 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16949 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384097, "i": 1882}}, "signature": {"hash": {"$binary": {"base64": "o44gyPI0Kv++BlcwhqBhb2b9tZo=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,859 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 6.079547 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16949 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC27610000076B2B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C7570646174650046646F63756D656E744B65790046645F6964006467BC27616DBD8CD539C8AB92000004"}, "operationType": "update", "clusterTime": {"$timestamp": {"t": 1740384097, "i": 1899}}, "wallTime": {"$date": "2025-02-24T08:01:37.857Z"}, "fullDocument": {"_id": {"$oid": "67bc27616dbd8cd539c8ab92"}, "platform": 1, "request": {"status": "211", "msg": "GIF消息回调", "data": {"msgContent": "<msg><emoji fromusername=\"wxid_znc2qvh26np321\" tousername=\"22149082331@chatroom\" type=\"2\" idbuffer=\"media:0_0\" md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" len=\"221429\" productid=\"\" androidmd5=\"bc6e46b075c99b551b78600e9c4dd3a6\" androidlen=\"221429\" s60v3md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v3len=\"221429\" s60v5md5=\"bc6e46b075c99b551b78600e9c4dd3a6\" s60v5len=\"221429\" cdnurl=\"http://vweixinf.tc.qq.com/110/20401/stodownload?m=bc6e46b075c99b551b78600e9 ...2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,859 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,859 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,859 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,859 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:37 sync run.sh[2616462]: 2025-02-24 16:01:37,860 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16950 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384097, "i": 1899}}, "signature": {"hash": {"$binary": {"base64": "o44gyPI0Kv++BlcwhqBhb2b9tZo=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,051 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,051 DEBUG [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Sending 6 records to topic robot.robot.orderly2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,051 DEBUG [io.deb.emb.asy.ParallelSmtAndConvertBatchProcessor] (pool-10-thread-1) Thread pool-10-thread-1 is submitting 6 records for processing.2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,058 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) polling records...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,058 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,378 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 517.933343 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16950 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC27620000017D2B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C696E736572740046646F63756D656E744B65790046645F6964006467BC27626DBD8CD539C8AB93000004"}, "operationType": "insert", "clusterTime": {"$timestamp": {"t": 1740384098, "i": 381}}, "wallTime": {"$date": "2025-02-24T08:01:38.373Z"}, "fullDocument": {"_id": {"$oid": "67bc27626dbd8cd539c8ab93"}, "platform": 1, "request": {"status": "203", "msg": "文本消息回调", "data": {"msgContent": "♥\ufe0f冷酸灵抗敏牙膏组合\n\n\ud83d\udcb027.9\ud83c\ude507件套❗\ufe0f\n\ud83d\udcb027.9\ud83c\ude507件套❗\ufe0f\n\n\ud83d\udd39美白护齿，修护敏感\n\ud83d\udd39抗敏配方，多效护理\n\nhttps://p.pinduoduo.com/IqeVj27d", "fromUserName": "wxid_gl3zvxzx5m8b22", "wechat": "wxid_gpve3wy2c6ea22", "username": null, "nickname": null, "fullContext": null, "toUserName": "53067432947@chatroom", "type": 0, "msgType": 1, "msgId": 1529245850, "newMsgId": 2121023673140088644, "buffer": "", "createTime": 1740384097000, "tar ...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,378 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,378 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,378 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,378 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,378 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16951 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384098, "i": 384}}, "signature": {"hash": {"$binary": {"base64": "+pZjbo0XIbTR39ZehS3Y7/dGkyA=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,409 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 30.414903 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16951 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC2762000001952B042C0100296E5A100444EF01863DB14F908F0A17DA8220C4AB463C6F7065726174696F6E54797065003C696E736572740046646F63756D656E744B65790046645F6964006467BC27626BF68F206999FE30000004"}, "operationType": "insert", "clusterTime": {"$timestamp": {"t": 1740384098, "i": 405}}, "wallTime": {"$date": "2025-02-24T08:01:38.406Z"}, "fullDocument": {"_id": {"$oid": "67bc27626bf68f206999fe30"}, "platform": 1, "request": {"status": "204", "msg": "图片消息回调", "data": {"msgContent": "<?xml version=\"1.0\"?>\n<msg>\n\t<img aeskey=\"24c50e6402f2440aa759a89594ad048c\" encryver=\"1\" cdnthumbaeskey=\"24c50e6402f2440aa759a89594ad048c\" cdnthumburl=\"3052020100044b304902010002042185ccae02033d12000204abbc892b020467bc2761042433333431303733652d303538322d343438322d623166302d3061303464646161363139300204052438010201000400\" cdnthumblength=\"5894\" cdnthumbheight=\"150\" cdnthumbwidth=\"150\" cdnmidheight=\"0\" cdnmidwidth=\"0\" cdnhdheight=\"0\" cdnhdwidth=\"0\" cd ...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,409 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,409 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,409 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,409 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,409 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16952 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384098, "i": 420}}, "signature": {"hash": {"$binary": {"base64": "+pZjbo0XIbTR39ZehS3Y7/dGkyA=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,415 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 5.670705 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16952 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC2762000001AF2B042C0100296E5A10044B1CD723929D40B8AADA64D5242E118D463C6F7065726174696F6E54797065003C7570646174650046646F63756D656E744B65790046645F6964006467BC27626DBD8CD539C8AB93000004"}, "operationType": "update", "clusterTime": {"$timestamp": {"t": 1740384098, "i": 431}}, "wallTime": {"$date": "2025-02-24T08:01:38.411Z"}, "fullDocument": {"_id": {"$oid": "67bc27626dbd8cd539c8ab93"}, "platform": 1, "request": {"status": "203", "msg": "文本消息回调", "data": {"msgContent": "♥\ufe0f冷酸灵抗敏牙膏组合\n\n\ud83d\udcb027.9\ud83c\ude507件套❗\ufe0f\n\ud83d\udcb027.9\ud83c\ude507件套❗\ufe0f\n\n\ud83d\udd39美白护齿，修护敏感\n\ud83d\udd39抗敏配方，多效护理\n\nhttps://p.pinduoduo.com/IqeVj27d", "fromUserName": "wxid_gl3zvxzx5m8b22", "wechat": "wxid_gpve3wy2c6ea22", "username": null, "nickname": null, "fullContext": null, "toUserName": "53067432947@chatroom", "type": 0, "msgType": 1, "msgId": 1529245850, "newMsgId": 2121023673140088644, "buffer": "", "createTime": 1740384097000, "tar ...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,415 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,415 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,415 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,415 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,416 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16953 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384098, "i": 432}}, "signature": {"hash": {"$binary": {"base64": "+pZjbo0XIbTR39ZehS3Y7/dGkyA=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,558 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,559 DEBUG [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Sending 2 records to topic robot.robot.orderly2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,559 DEBUG [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Sending 1 records to topic robot.robot.material2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,559 DEBUG [io.deb.emb.asy.ParallelSmtAndConvertBatchProcessor] (pool-10-thread-1) Thread pool-10-thread-1 is submitting 3 records for processing.2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,561 DEBUG [org.apa.kaf.con.sto.OffsetStorageWriter] (pool-10-thread-1) Submitting 1 entries to backing store. The offsets are: {{server_id=robot}={sec=1740384098, ord=431, resume_token=zQAAAAJfZGF0YQC9AAAAODI2N0JDMjc2MjAwMDAwMUFGMkIwNDJDMDEwMDI5NkU1QTEwMDQ0QjFDRDcyMzkyOUQ0MEI4QUFEQTY0RDUyNDJFMTE4RDQ2M0M2RjcwNjU3MjYxNzQ2OTZGNkU1NDc5NzA2NTAwM0M3NTcwNjQ2MTc0NjUwMDQ2NjQ2RjYzNzU2RDY1NkU3NDRCNjU3OTAwNDY2NDVGNjk2NDAwNjQ2N0JDMjc2MjZEQkQ4Q0Q1MzlDOEFCOTMwMDAwMDQAAA==}}2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,562 DEBUG [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Committing offset '{server_id=robot}' for partition '{sec=1740384098, ord=431, resume_token=zQAAAAJfZGF0YQC9AAAAODI2N0JDMjc2MjAwMDAwMUFGMkIwNDJDMDEwMDI5NkU1QTEwMDQ0QjFDRDcyMzkyOUQ0MEI4QUFEQTY0RDUyNDJFMTE4RDQ2M0M2RjcwNjU3MjYxNzQ2OTZGNkU1NDc5NzA2NTAwM0M3NTcwNjQ2MTc0NjUwMDQ2NjQ2RjYzNzU2RDY1NkU3NDRCNjU3OTAwNDY2NDVGNjk2NDAwNjQ2N0JDMjc2MjZEQkQ4Q0Q1MzlDOEFCOTMwMDAwMDQAAA==}'2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,562 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) polling records...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,562 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,608 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 192.50836 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16953 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC27620000027E2B042C0100296E5A100444EF01863DB14F908F0A17DA8220C4AB463C6F7065726174696F6E54797065003C7570646174650046646F63756D656E744B65790046645F6964006467BC27626BF68F206999FE30000004"}, "operationType": "update", "clusterTime": {"$timestamp": {"t": 1740384098, "i": 638}}, "wallTime": {"$date": "2025-02-24T08:01:38.605Z"}, "fullDocument": {"_id": {"$oid": "67bc27626bf68f206999fe30"}, "platform": 1, "request": {"status": "204", "msg": "图片消息回调", "data": {"msgContent": "<?xml version=\"1.0\"?>\n<msg>\n\t<img aeskey=\"24c50e6402f2440aa759a89594ad048c\" encryver=\"1\" cdnthumbaeskey=\"24c50e6402f2440aa759a89594ad048c\" cdnthumburl=\"3052020100044b304902010002042185ccae02033d12000204abbc892b020467bc2761042433333431303733652d303538322d343438322d623166302d3061303464646161363139300204052438010201000400\" cdnthumblength=\"5894\" cdnthumbheight=\"150\" cdnthumbwidth=\"150\" cdnmidheight=\"0\" cdnmidwidth=\"0\" cdnhdheight=\"0\" cdnhdwidth=\"0\" cd ...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,608 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,608 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,609 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,609 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,609 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16954 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384098, "i": 639}}, "signature": {"hash": {"$binary": {"base64": "+pZjbo0XIbTR39ZehS3Y7/dGkyA=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,976 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" succeeded on database "robot" in 367.025814 ms using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16954 and the operation ID is 33. Command reply: {"cursor": {"nextBatch": [{"_id": {"_data": "8267BC2762000004042B042C0100296E5A100444EF01863DB14F908F0A17DA8220C4AB463C6F7065726174696F6E54797065003C7265706C6163650046646F63756D656E744B65790046645F6964006467BC27626BF68F206999FE30000004"}, "operationType": "replace", "clusterTime": {"$timestamp": {"t": 1740384098, "i": 1028}}, "wallTime": {"$date": "2025-02-24T08:01:38.973Z"}, "fullDocument": {"_id": {"$oid": "67bc27626bf68f206999fe30"}, "platform": 1, "request": {"status": "204", "msg": "图片消息回调", "data": {"msgContent": "<?xml version=\"1.0\"?>\n<msg>\n\t<img aeskey=\"24c50e6402f2440aa759a89594ad048c\" encryver=\"1\" cdnthumbaeskey=\"24c50e6402f2440aa759a89594ad048c\" cdnthumburl=\"3052020100044b304902010002042185ccae02033d12000204abbc892b020467bc2761042433333431303733652d303538322d343438322d623166302d3061303464646161363139300204052438010201000400\" cdnthumblength=\"5894\" cdnthumbheight=\"150\" cdnthumbwidth=\"150\" cdnmidheight=\"0\" cdnmidwidth=\"0\" cdnhdheight=\"0\" cdnhdwidth=\"0\ ...2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,976 DEBUG [org.mon.dri.operation] (debezium-mongodbconnector-robot-replicator-fetcher-0) Received batch of 1 documents with cursorId 6820964614099926921 from server 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,976 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked in: address=172.31.42.206:3717, driver-generated ID=272月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,976 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Checkout started for connection to 172.31.42.206:37172月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,976 DEBUG [org.mon.dri.connection] (debezium-mongodbconnector-robot-replicator-fetcher-0) Connection checked out: address=172.31.42.206:3717, driver-generated ID=27, duration=0 ms2月 24 16:01:38 sync run.sh[2616462]: 2025-02-24 16:01:38,977 DEBUG [org.mon.dri.pro.command] (debezium-mongodbconnector-robot-replicator-fetcher-0) Command "getMore" started on database "robot" using a connection with driver-generated ID 27 and server-generated ID 19373184 to 172.31.42.206:3717. The request ID is 16955 and the operation ID is 33. Command: {"getMore": 6820964614099926921, "collection": "$cmd.aggregate", "$db": "robot", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1740384098, "i": 1030}}, "signature": {"hash": {"$binary": {"base64": "+pZjbo0XIbTR39ZehS3Y7/dGkyA=", "subType": "00"}}, "keyId": 7423657182211604482}}, "lsid": {"id": {"$binary": {"base64": "ei3UgY3bQQafBoBay0x2Qw==", "subType": "04"}}}}2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,062 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) checking for more records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,063 DEBUG [io.deb.con.com.BaseSourceTask] (pool-10-thread-1) Sending 1 records to topic robot.robot.material2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,063 DEBUG [io.deb.emb.asy.ParallelSmtAndConvertBatchProcessor] (pool-10-thread-1) Thread pool-10-thread-1 is submitting 1 records for processing.2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,065 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) polling records...2月 24 16:01:39 sync run.sh[2616462]: 2025-02-24 16:01:39,065 DEBUG [io.deb.con.bas.ChangeEventQueue] (pool-10-thread-1) no records available or batch size not reached yet, sleeping a bit...

      How to reproduce the issue using our tutorial deployment?

      <Your answer>

      Feature request or enhancement

      For feature requests or enhancements, provide this information, please:

      Which use case/requirement will be addressed by the proposed feature?

      <Your answer>

      Implementation ideas (optional)

      <Your answer>

              Unassigned Unassigned
              bain2018 Bain Lu (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: