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

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

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957863215 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/AbstractMQTTProcessor.java: ## @@ -289,88 +285,34 @@ publi

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957862534 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/AbstractMQTTProcessor.java: ## @@ -384,16 +326,59 @@ publi

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

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

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

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

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

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

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957859728 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/AbstractMQTTProcessor.java: ## @@ -384,16 +326,59 @@ publi

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

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

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

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

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

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

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957823553 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/MqttProtocolScheme.java: ## @@ -0,0 +1,30 @@ +/* + * Licen

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

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

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957817027 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/ConsumeMQTT.java: ## @@ -649,38 +625,44 @@ private void closeWrit

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957816155 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/ConsumeMQTT.java: ## @@ -649,38 +625,44 @@ private void closeWrit

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957814572 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/PublishMQTT.java: ## @@ -201,35 +191,35 @@ private void initializ

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957813444 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/PublishMQTT.java: ## @@ -201,35 +191,35 @@ private void initializ

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r957810380 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/PublishMQTT.java: ## @@ -201,35 +191,35 @@ private void initializ

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

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

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

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

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

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

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r956186934 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/ConsumeMQTT.java: ## @@ -402,42 +398,27 @@ private void initializ

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

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

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

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

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r953196811 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/AbstractMQTTProcessor.java: ## @@ -289,88 +288,35 @@ publi

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r952894224 ## 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] nandorsoma commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r952894025 ## 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] nandorsoma commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r95265 ## 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] nandorsoma commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r95265 ## 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] nandorsoma commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

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

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r952882215 ## 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 class Mq

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r952881717 ## 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 class Mq

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r952881239 ## 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 class Mq

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

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

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r952879664 ## 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] nandorsoma commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r952879128 ## 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] nandorsoma commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r945591904 ## 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] nandorsoma commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r945584486 ## 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] nandorsoma commented on a diff in pull request #6225: NIFI-10251 Add v5 protocol support for existing MQTT processors

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941205695 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-nar/src/main/resources/META-INF/NOTICE: ## @@ -41,6 +41,11 @@ The following binary components are provided under the Apac

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

nandorsoma commented on code in PR #6225: URL: https://github.com/apache/nifi/pull/6225#discussion_r941155396 ## nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/common/AbstractMQTTProcessor.java: ## @@ -199,16 +198,13 @@ publi