babubabu commented on code in PR #9604:
URL: https://github.com/apache/nifi/pull/9604#discussion_r1902063441
##########
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/PublishKafka.java:
##########
@@ -92,7 +92,8 @@
+ "The messages to send may be individual FlowFiles, may be delimited
using a "
+ "user-specified delimiter (such as a new-line), or "
+ "may be record-oriented data that can be read by the configured
Record Reader. "
- + "The complementary NiFi processor for fetching messages is
ConsumeKafka.")
+ + "The complementary NiFi processor for fetching messages is
ConsumeKafka. "
+ + "To produce a kafka tombstone message while using
PublishStrategy.USE_WRAPPER, simply set the value of a record to 'null'.")
Review Comment:
Sorry, I don't understand this point! Is this related to the Wrapper change
above (adding the tombstone attribute)?
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
