测试链路: Source(mqtt) → rule(透传) → Sink(Rest)
复现:
- mqtt source 一直发, Rest 目标 http 服务接收正常
- 目标 http 服务停掉,mqtt source 继续发几个消息,然后停止向 mqtt source 发送消息
- 目标 http 服务重新启动,没有收到停掉期间的 source 的几个消息
下面是 Rest Sink 的配置
测试链路: Source(mqtt) → rule(透传) → Sink(Rest)
复现:
下面是 Rest Sink 的配置