This is an automated email from the ASF dual-hosted git repository.
pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 4bcfc61 NIFI-9011 Correct tags in publish Kafka 2.6 processors
4bcfc61 is described below
commit 4bcfc615636ef2491847288656b816c752957d37
Author: Bryan Bende <[email protected]>
AuthorDate: Tue Oct 19 10:38:57 2021 -0400
NIFI-9011 Correct tags in publish Kafka 2.6 processors
Signed-off-by: Pierre Villard <[email protected]>
This closes #5464.
---
.../apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java | 4 ++--
.../org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java
index 8dbbdb9..a68b6f1 100644
---
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java
+++
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java
@@ -84,8 +84,8 @@ import static
org.apache.nifi.expression.ExpressionLanguageScope.VARIABLE_REGIST
import static
org.apache.nifi.processors.kafka.pubsub.KafkaProcessorUtils.FAILURE_STRATEGY;
import static
org.apache.nifi.processors.kafka.pubsub.KafkaProcessorUtils.FAILURE_STRATEGY_ROLLBACK;
-@Tags({"Apache", "Kafka", "Record", "csv", "json", "avro", "logs", "Put",
"Send", "Message", "PubSub", "2.5"})
-@CapabilityDescription("Sends the contents of a FlowFile as individual records
to Apache Kafka using the Kafka 2.5 Producer API. "
+@Tags({"Apache", "Kafka", "Record", "csv", "json", "avro", "logs", "Put",
"Send", "Message", "PubSub", "2.6"})
+@CapabilityDescription("Sends the contents of a FlowFile as individual records
to Apache Kafka using the Kafka 2.6 Producer API. "
+ "The contents of the FlowFile are expected to be record-oriented data
that can be read by the configured Record Reader. "
+ "The complementary NiFi processor for fetching messages is
ConsumeKafkaRecord_2_6.")
@InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED)
diff --git
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java
index e9f5930..32ae23a 100644
---
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java
+++
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java
@@ -69,8 +69,8 @@ import static
org.apache.nifi.expression.ExpressionLanguageScope.FLOWFILE_ATTRIB
import static
org.apache.nifi.processors.kafka.pubsub.KafkaProcessorUtils.FAILURE_STRATEGY;
import static
org.apache.nifi.processors.kafka.pubsub.KafkaProcessorUtils.FAILURE_STRATEGY_ROLLBACK;
-@Tags({"Apache", "Kafka", "Put", "Send", "Message", "PubSub", "2.5"})
-@CapabilityDescription("Sends the contents of a FlowFile as a message to
Apache Kafka using the Kafka 2.5 Producer API."
+@Tags({"Apache", "Kafka", "Put", "Send", "Message", "PubSub", "2.6"})
+@CapabilityDescription("Sends the contents of a FlowFile as a message to
Apache Kafka using the Kafka 2.6 Producer API."
+ "The messages to send may be individual FlowFiles or may be delimited,
using a "
+ "user-specified delimiter, such as a new-line. "
+ "The complementary NiFi processor for fetching messages is
ConsumeKafka_2_6.")
