HTTP Sink 集成

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

前提条件

• 已了解管道结构与创建流程，参考 数据集成；Sink 连接器总览见 Sink
• 目标 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 · 示例场景。

可参考以下参数示例：

参数	建议值
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。

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

参数建议

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

注意事项

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