Kafka Connect写入MongoDB报Double类型无对应转换器异常

• MongoDB是文档型数据库，配套的Kafka Sink连接器默认只接受可转换为BSON文档（键值对结构化对象）的消息值，原生不支持直接写入原始基础类型标量值（比如你输出的java.lang.Double）。
• 触发异常的直接问题有两个：
  1. 转换器配置错误：StringConverter、DoubleConverter都是给原始标量类型用的转换器，本身不输出带Schema的结构化数据，你配置的*.converter.schemas.enable=true属于无效配置，还会干扰连接器的类型识别逻辑。
  2. Kafka Streams直接往目标主题写入裸Double值。连接器消费到消息后，虽然能正常把字节反序列化成Double类型，但后续要转成BSON写入Mongo的时候，发现拿到的是个裸数值而不是结构化对象，找不到对应转换逻辑，直接抛出类型不匹配异常。

两种方案按需选择即可：

方案1：不修改上游代码，仅调整连接器配置（快速修复） #

利用连接器自带的原始值包装能力，自动把裸Double包装成合法BSON文档：

• 把两个转换器的schemas.enable都改成false，移除无效配置
• 配置字段包装规则，让连接器自动把裸值放到指定字段下生成合法文档
• 配置独立的文档ID生成策略，不要直接拿原始数值作为文档ID

修正后的完整连接器配置：

curl -X PUT http://localhost:8083/connectors/sink-mongodb-users/config -H "Content-Type: application/json" -d '{
    "connector.class":"com.mongodb.kafka.connect.MongoSinkConnector",
    "tasks.max":"1",
    "topics":"MOVINGAVG",
    "connection.uri":"mongodb://mongo:27017",
    "database":"Temperature",
    "collection":"MovingAverage",
    "key.converter":"org.apache.kafka.connect.storage.StringConverter",
    "key.converter.schemas.enable":"false",
    "value.converter":"org.apache.kafka.connect.converters.DoubleConverter",
    "value.converter.schemas.enable":"false",
    "mongo.field.wrapper": "avg_value",
    "document.id.strategy": "com.mongodb.kafka.connect.sink.processor.id.strategy.UuidStrategy"
}'

该配置会自动把传入的Double值包装为{"avg_value": 2.1474836E7}格式的文档写入Mongo，重启连接器即可生效，无需修改Streams代码。

方案2：调整Kafka Streams输出结构（长期推荐） #

该方案更符合Kafka Connect和MongoDB的设计约定，后续扩展业务字段更方便：

1. 调整Streams代码，不要直接输出裸Double值，把平均值包装为带明确业务语义的结构化对象，比如可以带上窗口起止时间、指标标识、平均值等字段，使用JSON序列化（如Jackson Serde）后输出到目标主题。
2. 把连接器的value转换器替换为org.apache.kafka.connect.json.JsonConverter，关闭schema支持即可，核心配置片段：

"value.converter":"org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable":"false"

这种方式写入的文档结构清晰，不依赖连接器的隐式包装逻辑，跨版本兼容性更好，不容易出现隐式转换导致的诡异问题。

内容的提问来源于stack exchange，提问作者krysznys