ekuiper icon indicating copy to clipboard operation
ekuiper copied to clipboard

mqtt sink server param no longer accepts path

Open ngjaying opened this issue 1 year ago • 0 comments

Discussed in https://github.com/lf-edge/ekuiper/discussions/2827

Originally posted by wtflanders May 2, 2024 Hi, it's been a while since I updated my eKuiper version, I've been running on v1.4.2. The "server" param of an mqtt sink rule with 1.4.2 could have a / on the endpoint:
"server": "wss://hostname.x.com:443/mqtt"

Testing v1.13.3 I get a "server is missing" error when I add the /mqtt path portion to the endpoint.... and my connecting broker requires it.
Is there a way around this? When did it change? Thx.

Here is my rule: { "ID": "postAlive", "SQL": "SELECT ts FROM alive_stream", "Actions": [ { "mqtt": { "server": "wss://host.x.com:443/mqtt", "clientId": "alive-host.micron.com", "password": "abcdefg", "sendSingle": true, "topic": "host/alive", "username": "newusr" } } ] }

ngjaying avatar May 04 '24 02:05 ngjaying