---
title: Source
---

# Source

Source 是数据管道的**入口**：负责从 FlowMQ 或外部系统读取数据，再交给后续 Processors / Sink。

## 适用场景

- 从 Kafka、MQTT、RabbitMQ、NATS 等消息系统读取数据
- 从 FlowMQ 数据流（Kafka Topic）读取数据，再输出到其他目标
- 在进入处理逻辑前做接入侧校验与连通性确认

## 配置要点

在创建管道向导的 **Source** 步骤中：

1. 选择来源连接器类型
2. 填写连接参数
3. 点击「测试」验证连通性（通过后才能继续）

完整创建流程见 [数据集成](data-integration.md)。

## Source 选择建议

- **Kafka**：适合高吞吐消息接入；也可作为读取 FlowMQ 数据流的来源
- **MQTT**：适合 IoT 设备数据接入
- **RabbitMQ / NATS**：适合现有消息系统迁移或汇聚

## Source 连接器

- [Kafka Source](data-integration-source-kafka.md)
- [RabbitMQ Source](data-integration-source-rabbitmq.md)
- [MQTT Source](data-integration-source-mqtt.md)
- [NATS Source](data-integration-source-nats.md)

## 注意事项

- 先完成 Source 连通性验证，再继续后续步骤
- Source 与 Sink 均可连接 FlowMQ 或外部系统，按实际链路组合即可