NATS Source 集成

本文介绍如何在管道的 Source 步骤中使用 NATS 作为数据来源。

适用场景

• 接入低延迟消息链路
• 对接已有 NATS 发布系统

前提条件

• 已了解管道结构与创建流程，参考 数据集成；Source 连接器总览见 Source
• NATS 服务可访问
• 已准备订阅 subject 与认证配置

配置步骤

1. 在“数据管道”中创建管道，完成基础信息配置。
2. 在 Source 步骤选择 NATS。
3. 配置 urls、subject 等参数。
4. 点击“测试”验证连接。
5. 继续完成 Processors、Sink 与确认步骤。

配置示例

可参考以下参数示例：

参数	建议值
urls	127.0.0.1:4222
subject	flowmq.mqtt.kafka
prefetch_count	524288（默认）

必要表单参数

以表单中带 * 的字段为必填：

参数	说明
urls*	NATS 服务地址列表
subject*	订阅 subject（支持通配符）
auto_replay_nacks*	下游拒绝（nack）时是否自动重放

常用非必填项：

参数	说明
queue	可选 queue group
prefetch_count	单次拉取消息上限
auth	NKey / JWT 等鉴权配置

参数建议

• 使用可读的 subject 层级规划
• 多消费者竞争消费时配置 queue
• 根据负载调优 prefetch_count 与重连参数

注意事项

• 关注消息顺序与消费语义
• 高并发场景建议压测后上线
• 接入后的字段清洗与映射见 Processors