使用Vector.dev HTTP Sink向OpenMeter发送数据失败问题排查

核心问题 #

直接curl单条CloudEvent能成功，但Vector的HTTP Sink发送失败，原因是Vector默认会批量打包事件为JSON数组，而你配置的Content-Type是单条CloudEvent的类型，导致OpenMeter无法解析请求体，返回400错误。

OpenMeter的/api/v1/events端点支持两种请求格式：

• 单条事件：Content-Type: application/cloudevents+json，请求体为单个JSON对象
• 批量事件：Content-Type: application/cloudevents-batch+json，请求体为JSON数组

你的curl请求是单条格式，但Vector默认批量发送时会生成数组，却用了单条的Content-Type，导致格式不匹配。

解决方案 #

方案1：使用批量发送格式（推荐，性能更优） #

修改HTTP Sink的Content-Type为批量类型，适配Vector的默认批量行为：

sinks:
  openmeter_sink:
    type: http
    inputs:
      - om_two
    uri: "http://openmeter:8888/api/v1/events"
    method: "post"
    encoding:
      codec: "json"
    headers:
      Content-Type: "application/cloudevents-batch+json"  # 改为批量CloudEvents类型
    healthcheck:
      enabled: false
    # 可选：调整批量参数，根据业务需求设置
    batch:
      max_events: 100
      timeout_secs: 1

方案2：强制单条发送事件 #

设置Vector每次仅发送1条事件，保持单条CloudEvents的Content-Type：

sinks:
  openmeter_sink:
    type: http
    inputs:
      - om_two
    uri: "http://openmeter:8888/api/v1/events"
    method: "post"
    encoding:
      codec: "json"
    headers:
      Content-Type: "application/cloudevents+json"
    healthcheck:
      enabled: false
    # 强制每次发送1条事件
    batch:
      max_events: 1
    # 确保请求并发数为1，避免批量打包
    request:
      concurrency: 1

验证步骤 #

1. 确认事件格式：添加console sink输出转换后的事件，确保和curl发送的结构一致：

   sinks:
     debug_console:
       type: console
       inputs:
         - om_two
       encoding:
         codec: json
   

2. 查看请求详情：开启Vector debug日志，查看实际发送的请求体：
   在配置顶部添加：

   log_level: debug
   

   启动后可在日志中看到完整的请求内容，验证是否为数组/单条对象。

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