Kafka Connect - 没有 $numberLong 的 Mongo 到 JSON

问题描述

我正在使用 Kafka Connect MongoSourceConnector 将数据从数据库读取到 Kafka。这是可行的，但它总是以奇怪的 Mongo 格式为长数字格式的字段输出数据。

这是我的 Kafka 连接 JSON 配置：

{
    "name": "mongo-source","config": {
        "connector.class": "com.mongodb.kafka.connect.MongoSourceConnector","tasks.max": "1","connection.uri": "<my mongo connection>","database": "<my database>","collection": "<my collection>","topic.prefix": "<my topic prefix>","poll.max.batch.size": "1000","poll.await.time.ms": "5000","batch.size": "0","change.stream.full.document": "updateLookup","value.converter": "org.apache.kafka.connect.storage.StringConverter","key.converter": "org.apache.kafka.connect.json.JsonConverter","key.converter.schemas.enable": "false","value.converter.schemas.enable": "false","pipeline": "[{$project:{\"fullDocument\":1}}]"
    }
}

实际输出如下：

{
    "fullDocument": {
        "foo": {
            "$numberLong": "42"
        },"bar": {
            "othernested": {
                "$numberLong": "24"
            }
        }
    }
}

这是我想要的：

{
    "fullDocument": {
        "foo": 42,"bar": {
            "othernested": 24
        }
    }
}

有没有办法得到这样的输出？

感谢您的帮助。

解决方法

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

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

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

apache-kafka-connect json mongodb mongodb mongodb-kafka-connector