可以看下 Mqtt Sink 的文档,是不是一些权限配置没有配置:
https://ekuiper.org/docs/zh/latest/guide/sinks/builtin/mqtt.html
源能运行起来时,规则就运行不起来,规则能运行起来时,流就接收不到消息, 都是共用connectionSelector: mqtt.localConnection连接器,反证现象就是source和sinks不能同时工作,除非是用不同的MQTT客户端