Rest Sink 属性:resendInterval 是否生效

测试链路: Source(mqtt) → rule(透传) → Sink(Rest)
复现

  • mqtt source 一直发, Rest 目标 http 服务接收正常
  • 目标 http 服务停掉,mqtt source 继续发几个消息,然后停止向 mqtt source 发送消息
  • 目标 http 服务重新启动,没有收到停掉期间的 source 的几个消息

下面是 Rest Sink 的配置

Rest sink 目前没有判断是连接问题还是数据问题导致发送失败,所以没有缓存重试。能否麻烦您简单在 Github 开个issue,我们解决一下

https://github.com/lf-edge/ekuiper/issues/1768