Sujesh Menon created NIFI-5991: ---------------------------------- Summary: ConsumeMQTT doensn't support MQTT over websockets Key: NIFI-5991 URL: https://issues.apache.org/jira/browse/NIFI-5991 Project: Apache NiFi Issue Type: Improvement Affects Versions: 1.8.0 Reporter: Sujesh Menon
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, -- This message was sent by Atlassian JIRA (v7.6.3#76005)