---
title: HTTP Sink 集成
---

# HTTP Sink 集成

本文介绍如何将 FlowMQ 数据通过 HTTP 写入外部服务。

## 前提条件

- 已了解管道结构与创建流程，参考 [数据集成](data-integration.md)；Sink 连接器总览见 [Sink](data-integration-output.md)
- 目标 HTTP 服务可访问
- 已准备鉴权方式与接口约定

## 配置步骤

1. 在“数据管道”中创建管道，完成基础信息配置。
2. 在 Source 步骤选择 `Kafka`（Topic：`flowmq.mqtt.kafka`），Processors 按需配置。
3. 在 Sink 步骤选择 `HTTP`，配置 `url`、`verb` 等参数。
4. 点击“测试”验证连接。
5. 继续完成确认步骤。

## 配置示例

以下示例将 Kafka Topic `flowmq.mqtt.kafka` 中的样例消息写入目标系统。样例 JSON 与 Source 约定见 [Sink · 示例场景](data-integration-output.md#示例场景)。

可参考以下参数示例：

| 参数 | 建议值 |
|---|---|
| url | `http://127.0.0.1:18099/ingest`（请改为实际服务地址；勿占用文档预览常用的 `8080`） |
| verb | `POST` |
| timeout | `5s` |
| max_in_flight | `64` |
| retries | `3` |

> 请求体为 Kafka 中的样例 JSON；目标接口可按 `source`、`data.value` 等字段解析。

## 必要表单参数

参数名后带 `*` 表示控制台必填。「支持表达式」为「是」时，可使用 `${! ... }` 按消息动态取值，详见 [Processors](data-integration-processors-expressions.md)。

| 参数 | 支持表达式 | 说明 |
|------|------------|------|
| `url*` | 是 | HTTP 目标地址 |
| `verb*` | 否 | 请求方法（如 POST） |
| `timeout` | 否 | 请求超时时间 |
| `max_in_flight*` | 否 | 并发请求上限 |
| `retries` | 否 | 重试次数 |

## 参数建议

- `url` 宜指向具备幂等能力的接口
- `retries` 建议显式配置，并评估重复写入风险

## 注意事项

- 控制台「测试」向 `url` 发送 HEAD 请求，仅验证可达性
- 目标接口建议具备幂等能力，并评估重试导致的重复写入