Drop Sink 集成
本文介绍如何使用 Drop Sink。Drop Sink 会丢弃所有输出消息,不写入外部系统。
前提条件
配置步骤
- 在“数据管道”中创建管道,完成基础信息配置。
- 在 Source 步骤选择
Kafka(Topic:flowmq.mqtt.kafka),Processors 按需配置。 - 在 Sink 步骤选择
Drop sink(无需连接参数,也无需测试)。 - 继续完成确认步骤。
配置示例
可沿用 Sink · 示例场景 中的 Kafka Source 与样例消息完成配置。Drop sink 本身无需填写连接参数。
必要表单参数
参数名后带 * 表示控制台必填。「支持表达式」为「是」时,可使用 ${! ... } 按消息动态取值,详见 Processors。
| 参数 | 支持表达式 | 说明 |
|---|---|---|
| 无 | — | Drop sink 不需要填写连接参数 |
参数建议
- 仅用于验证 Source / Processors;验证完成后请切换到正式 Sink
注意事项
- Drop Sink 不保留消息,不可用于正式数据落地
- 建议仅短期用于流程验证