[GitHub] [nifi] nandorsoma commented on a diff in pull request #6530: NIFI-10644 Add Message Demarcator-style processing in PublishMQTT

[GitBox <gi...@apache.org>]

nandorsoma commented on code in PR #6530:
URL: https://github.com/apache/nifi/pull/6530#discussion_r996491653


##########
nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/PublishMQTT.java:
##########
@@ -109,6 +113,15 @@ public class PublishMQTT extends AbstractMQTTProcessor implements MqttCallback {
             .description("The Record Writer to use for serializing Records before publishing them as an MQTT Message.")
             .build();
 
+    public static final PropertyDescriptor MESSAGE_DEMARCATOR = new PropertyDescriptor.Builder()
+            .fromPropertyDescriptor(BASE_MESSAGE_DEMARCATOR)
+            .description("With this property, you have an option to publish multiple messages from a single FlowFile. "
+                    + "This property allows you to provide a string (interpreted as UTF-8) to use for splitting "
+                    + "the FlowFile content. This is an optional property ; if not provided, and if not defining a "
+                    + "Record Reader/Writer, each message received will result in a single FlowFile. To enter special "

Review Comment:
   Oh, I tried to match this description to the processor, but seems like I missed this sentence. Thx.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@nifi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org