[NIFI-5991] ConsumeMQTT doesn't support MQTT over websockets

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.8.0
• Fix Version/s: 1.9.0
• Labels: easyfix features
• Assignee: Unassigned
• Reporter: Sujesh Menon
• Created: 31/Jan/19 21:15
• Updated: 04/Feb/19 15:03
• Resolved: 04/Feb/19 15:03

Description

The Broker URI property of  ConsumeMQTT processor only supports 'tcp' and 'ssl' scheme, Though the org.eclipse.paho.client.mqttv3.MqttClient allows MQTT over WebSockets i.e with the "ws" or "wss" scheme in the broker URI. This could be fixed by adding these schemes to  the BROKER_VALIDATOR  in AbstractMQTTProcessor class, 

Issue Links

• links to: GitHub Pull Request #3289