Mongo 到 Kafka 连接器

问题描述

在 Mongo 到 Kafka 连接器上工作并遇到这个问题，当消息从 mongo 转储到 kafka 主题时，它会添加斜杠

rs0:PRIMARY> db.mongotokafka.insert({"key6":"value6"}) –the original data doesn’t have slash

WriteResult({ "nInserted" : 1 })

[azureuser@kafkamongo config]$ kafka-console-consumer.sh --topic mongotokafka.mongotokafka --from-beginning --bootstrap-server localhost:9092

"{\"_id\": {\"$oid\": \"60a89f08ced2363865352271\"},\"key5\": \"value5\"}" –see the slash

"{\"_id\": {\"$oid\": \"60a89f4d33a3d2ce1af793cb\"},\"key6\": \"value6\"}"–see the slash

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）