微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Mongo 到 Kafka 连接器

如何解决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 举报,一经查实,本站将立刻删除。