Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.0.0, 0.7.0, 0.6.1
-
None
-
None
Description
Today NiFi only supports MQTT over plain TCP using the PublishMQTT and ConsumeMQTT processors. However, there are many cases in the IoT world where WebSockets (secure and not) is the preferred transport mechanism for MQTT. This JIRA is to enhance those processors to also support WS.
Following are the basics of what is required:
1) Require to configure web socket as the transport protocol, currently PublishMQTT processor supports TCP as the only transport protocol
2) URL input for the Web socket transport should be in the format of ws://IPAddress:websocket_listening_port, as of now it accepts only TCP url, and a bulletin is raised if a protocol other than tcp or ssl is used.
3) Similar to TCP non-secured and secured publisher we should extend/provide processor to support WS and WSS transport protocols
