使用Alpakka向Elasticsearch写入文档失败，请求协助排查

先从VolResult case类和ES索引映射的匹配度入手，这是最常见的bulk失败原因，重点查这几个地方：

1. 字段名称与序列化配置 #

ES对字段名大小写敏感，多数场景下ES用下划线命名（比如vol_id），但Scala case类习惯用驼峰（volId），如果没做序列化配置，Jackson会直接把驼峰字段名传给ES，导致和映射不匹配。解决办法是给case类字段加Jackson注解指定ES字段名：

import com.fasterxml.jackson.annotation.JsonProperty
import com.fasterxml.jackson.annotation.JsonFormat
import java.time.LocalDateTime

case class VolResult(
  @JsonProperty("vol_id") volId: String,
  @JsonProperty("create_time") 
  @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") 
  createTime: LocalDateTime,
  total: Double
)

如果是日期类型，必须保证序列化后的格式和ES映射的format完全一致。

2. 字段类型严格匹配 #

对照ES索引映射的每个字段类型，检查case类的Scala类型：

• ES的integer对应Scala的Int，long对应Long，double对应Double
• ES的text/keyword对应Scala的String
• 若为嵌套类型，case类的嵌套结构要和ES的nested字段完全一致，子字段的名称、类型都不能出错

3. 对比Alpakka生成的请求与DevTools成功请求 #

把Alpakka实际发送的bulk请求内容打印出来（可开启调试日志，或在代码里手动序列化case类查看结果），和你在DevTools中能成功的请求逐行对比：

• 检查bulk结构：必须是一行操作指令（比如{"index": {"_index": "your_index"}}）加一行文档内容，不能有语法错误（比如少引号、多逗号）
• 检查文档的字段名、值的格式，比如日期字符串是否符合映射要求，数值类型有没有误传为字符串

4. 从错误日志定位精准问题 #

ES返回的错误日志里会明确给出失败原因：

• 若为mapper_parsing_exception，会直接指出哪个字段不符合映射规则
• 若为illegal_argument_exception，大概率是bulk请求的结构错误

快速验证技巧 #

把你的VolResult实例手动序列化成JSON，和DevTools里的成功文档对比：

import com.fasterxml.jackson.databind.ObjectMapper
import com.fasterxml.jackson.module.scala.DefaultScalaModule

val mapper = new ObjectMapper().registerModule(DefaultScalaModule)
val testResult = VolResult(...) // 填入你的测试数据
println(mapper.writeValueAsString(testResult))

如果输出的JSON和DevTools里的不一致，直接调整case类的注解或字段定义即可。

内容的提问来源于stack exchange，提问作者blue-sky