Source

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

适用场景

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

配置要点

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

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

完整创建流程见 数据集成。

Source 选择建议

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

Source 连接器

• Kafka Source
• RabbitMQ Source
• MQTT Source
• NATS Source

注意事项

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