Vector HTTP Sink无法向我的服务发送HTTP请求，该如何处理？

我的服务无法接收来自Vector HTTP Sink的HTTP请求，相关信息如下：

Sink配置 #

"sinks": {
        "console_sink": {
            "type": "console",
            "inputs": [
               "vector_http_test_transform"
            ],
            "encoding": {
                "codec": "json"
            }
       },
       "my_http_sink": {
           "type": "http",
           "inputs": [
              "vector_http_test_transform"
           ],
          "method": "post", 
          "encoding": {
               "codec": "json"
           },
           "request": {
               "headers": {
                 "Content-Type": "application/json"
               }
           },
           "uri": "http://myHost:myPort/logs"
       }
    }

控制台输出（事件示例） #

{"file":"/data/logs/n9e-logs/test.log","host":"host.novalocal","message":{"level":"INFO","lineNumber":"21","logDate":"2024-09-24 15:19:14.660963","message":"event(c695d938d8955d triggered) push_queue: rule_id=47 tags:[__name__=mem_used_percent data_group=tok_3dc2a5e1457744379dad ]  2024-09-20 15:19:14.000 ","method":"dispatch/log.go"},"source_type":"file","timestamp":"2024-09-26T02:19:30.405"}

测试验证 #

使用curl直接请求服务可正常接收：

curl -X POST http://myHost:myPort/logs -H "Content-Type: application/json" -d '{"key":"value"}'

但服务始终无法收到来自Vector HTTP Sink的请求，该如何解决？

• 强制立即发送请求（避免批量等待）：Vector默认会批量聚合事件后发送，可能导致看起来没请求的情况。添加批量配置强制单条发送测试：

  "my_http_sink": {
      // 保留原有配置
      "batch": {
          "max_events": 1,
          "timeout_secs": 1
      }
  }
  

• 查看Vector调试日志：调高Vector日志级别，排查请求失败的具体原因。启动时添加参数：

  vector --log-level debug
  

  重点关注包含my_http_sink的日志，比如连接超时、DNS解析失败、服务返回错误码等信息。

• 验证网络连通性：在Vector运行的机器上，测试目标服务端口是否可达：

  # 使用telnet测试
  telnet myHost myPort
  # 或者用nc
  nc -zv myHost myPort
  

  确认无防火墙、网络策略拦截Vector的请求。

• 调整请求内容格式：Vector默认批量发送时会输出JSON数组，若服务仅支持单个JSON对象，可修改编码配置：

  "encoding": {
      "codec": "json",
      "format": "newline_delimited"
  }
  

• 对比请求差异：用tcpdump或wireshark抓取Vector和curl的请求，对比请求头、HTTP版本、请求体格式。比如Vector默认用HTTP/2，若服务仅支持HTTP/1.1，可强制指定：

  "my_http_sink": {
      // 保留原有配置
      "request": {
          "version": "1.1"
      }
  }
  

• 检查TLS/代理配置：若目标服务用HTTPS，确保uri使用https://，并按需配置tls参数；若需要代理，添加proxy配置项。

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