Details
-
Question
-
Resolution: Gone away
-
Major - P3
-
None
-
1.9.1
-
None
-
None
Description
Original title: 通过连接器获取的数据,是带有“ and \ 和转义符号的无法解析的json字符串,而不是json.tostring()所获取的jsonString
This is the description of the source connection:
{"connector.class":"com.mongodb.kafka.connect.MongoSourceConnector",
|
"mongo.errors.deadletterqueue.topic.name":"conn_error_data",
|
"publish.full.document.only":"false",
|
" mongo.errors.log.enable":"true",
|
"startup.mode":"copy_existing",
|
"tasks.max":"2",
|
"change.stream.full.document":"updateLookup",
|
"collection" :"",
|
"mongo.errors.tolerance":"all",
|
"database":"****",
|
"topic.prefix":"mongo-cdc1",
|
"topic.separator":"_",
|
" connection.uri":"mongodb://user:pass@mongo1:27017,mongo2:27017,mongo3:27017" ,
|
“姓名”:"mongo-cdc-chatbot"}
|
以下是获取的数据: (The following is the data obtained )
“{\“_ID\”: {\"_data\": \"8263EA11F300000A002B022C0100296E5A10044626960F9B9E4F8A8CCB5B7FB645F88746645F6964006463E30D187FA0165B25002E010004\"}
|
, \"operationType\": \"delete\", \"clusterTime\": \{\"$timestamp\": {\"t\": 1676284403, \"i\": 2560}}, \"ns\ ": \{\"db\": \"chatbot\", \"coll\": \"test\"}, \"documentKey\": {\"_id\":
|
{\"$oid\": \"63e30d187fa0165b25002e01\"}}}"
|
When parsing:
通过BSONDocumeng.parse(str)解析是出现的错误:
|
|
|
readStartDocument 只能在 CurrentBSONType 为 DOCUMENT 时调用,不能在 CurrentBSONType 为 STRING 时调用。
|