---
title: NATS Source 集成
---

# NATS Source 集成

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

## 适用场景

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

## 前提条件

- 已了解管道结构与创建流程，参考 [数据集成](data-integration.md)；Source 连接器总览见 [Source](data-integration-input.md)
- 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](data-integration-processors-expressions.md)