greyp9 commented on code in PR #9604:
URL: https://github.com/apache/nifi/pull/9604#discussion_r1904433037
##########
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:
I was talking myself through the tradeoffs. For USE_WRAPPER, this
documentation seems fine. No request here.
--
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]
