ekuiper使用connectionSelector: mqtt.localConnection连接器,sinks中添加了mqtt.yaml定义test资源,引用到创建规则中动作,规则运行不起来




可以看下 Mqtt Sink 的文档,是不是一些权限配置没有配置:

https://ekuiper.org/docs/zh/latest/guide/sinks/builtin/mqtt.html

源能运行起来时,规则就运行不起来,规则能运行起来时,流就接收不到消息, 都是共用connectionSelector: mqtt.localConnection连接器,反证现象就是source和sinks不能同时工作,除非是用不同的MQTT客户端