[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957965217 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/AbstractMQTTProcessor.java: ## @@ -31,89 +31,94 @@

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957500825 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/AbstractMQTTProcessor.java: ## @@ -31,89 +31,89 @@

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r945709768 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/adapters/HiveMqV5ClientAdapter.java: ## @@ -0,0 +1,194 @@ +

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941410795 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/adapters/HiveMqV5ClientAdapter.java: ## @@ -0,0 +1,194 @@ +

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941410138 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/adapters/HiveMqV5ClientAdapter.java: ## @@ -0,0 +1,194 @@ +

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941407304 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/MqttConstants.java: ## @@ -67,14 +69,45 @@ public cl

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941406015 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/NifiMqttMessage.java: ## @@ -0,0 +1,67 @@ +/* + * Li

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941405400 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/NifiMqttClient.java: ## @@ -0,0 +1,27 @@ +/* + * Lic

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941398697 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/adapters/HiveMqV5ClientAdapter.java: ## @@ -0,0 +1,194 @@ +

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941321632 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/AbstractMQTTProcessor.java: ## @@ -199,7 +199,7 @@ p

[GitHub] [nifi] exceptionfactory commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

exceptionfactory commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941319081 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/AbstractMQTTProcessor.java: ## @@ -199,7 +199,7 @@ p