This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch support/nifi-1.x
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/support/nifi-1.x by this push:
new 107583ac20 NIFI-11181 Deprecated Kafka 1.x components
107583ac20 is described below
commit 107583ac20a2bcfe716c32add8ddd984828272ba
Author: Pierre Villard <[email protected]>
AuthorDate: Tue Feb 14 16:32:31 2023 -0500
NIFI-11181 Deprecated Kafka 1.x components
This closes #6954
Signed-off-by: David Handermann <[email protected]>
---
.../org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaRecord_1_0.java | 2 ++
.../java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_1_0.java | 2 ++
.../org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_1_0.java | 2 ++
.../java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_1_0.java | 2 ++
.../java/org/apache/nifi/record/sink/kafka/KafkaRecordSink_1_0.java | 2 ++
5 files changed, 10 insertions(+)
diff --git
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaRecord_1_0.java
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaRecord_1_0.java
index 1dbe5ed3dd..351729d1d7 100644
---
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaRecord_1_0.java
+++
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaRecord_1_0.java
@@ -36,6 +36,7 @@ import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.behavior.WritesAttributes;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
+import org.apache.nifi.annotation.documentation.DeprecationNotice;
import org.apache.nifi.annotation.documentation.SeeAlso;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnStopped;
@@ -68,6 +69,7 @@ import org.apache.nifi.serialization.RecordSetWriterFactory;
+ "'parse.failure' relationship. Otherwise, each FlowFile is sent to the
'success' relationship and may contain many individual messages within the
single FlowFile. "
+ "A 'record.count' attribute is added to indicate how many messages are
contained in the FlowFile. No two Kafka messages will be placed into the same
FlowFile if they "
+ "have different schemas, or if they have different values for a message
header that is included by the <Headers to Add as Attributes> property.")
+@DeprecationNotice(classNames =
"org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_6")
@Tags({"Kafka", "Get", "Record", "csv", "avro", "json", "Ingest", "Ingress",
"Topic", "PubSub", "Consume", "1.0"})
@WritesAttributes({
@WritesAttribute(attribute = "record.count", description = "The number of
records received"),
diff --git
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_1_0.java
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_1_0.java
index 772f6cfa5e..a834ff4607 100644
---
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_1_0.java
+++
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_1_0.java
@@ -36,6 +36,7 @@ import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.behavior.WritesAttributes;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
+import org.apache.nifi.annotation.documentation.DeprecationNotice;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnStopped;
import org.apache.nifi.annotation.lifecycle.OnUnscheduled;
@@ -62,6 +63,7 @@ import org.apache.nifi.processor.util.StandardValidators;
@CapabilityDescription("Consumes messages from Apache Kafka specifically built
against the Kafka 1.0 Consumer API. "
+ "The complementary NiFi processor for sending messages is
PublishKafka_1_0.")
+@DeprecationNotice(classNames =
"org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_2_6")
@Tags({"Kafka", "Get", "Ingest", "Ingress", "Topic", "PubSub", "Consume",
"1.0"})
@WritesAttributes({
@WritesAttribute(attribute = KafkaFlowFileAttribute.KAFKA_COUNT,
description = "The number of messages written if more than one"),
diff --git
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_1_0.java
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_1_0.java
index 69805eb706..56165625fa 100644
---
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_1_0.java
+++
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_1_0.java
@@ -23,6 +23,7 @@ import org.apache.nifi.annotation.behavior.DynamicProperty;
import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
+import org.apache.nifi.annotation.documentation.DeprecationNotice;
import org.apache.nifi.annotation.documentation.SeeAlso;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnStopped;
@@ -82,6 +83,7 @@ import static
org.apache.nifi.expression.ExpressionLanguageScope.FLOWFILE_ATTRIB
@CapabilityDescription("Sends the contents of a FlowFile as individual records
to Apache Kafka using the Kafka 1.0 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_1_0.")
+@DeprecationNotice(classNames =
"org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_2_6")
@InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED)
@DynamicProperty(name = "The name of a Kafka configuration property.", value =
"The value of a given Kafka configuration property.",
description = "These properties will be added on the Kafka configuration
after loading any provided configuration properties."
diff --git
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_1_0.java
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_1_0.java
index 6de516be7d..5ba93eb80d 100644
---
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_1_0.java
+++
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_1_0.java
@@ -23,6 +23,7 @@ import org.apache.nifi.annotation.behavior.DynamicProperty;
import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
+import org.apache.nifi.annotation.documentation.DeprecationNotice;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnStopped;
import org.apache.nifi.components.AllowableValue;
@@ -73,6 +74,7 @@ import static
org.apache.nifi.expression.ExpressionLanguageScope.FLOWFILE_ATTRIB
+ "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_1_0.")
+@DeprecationNotice(classNames =
"org.apache.nifi.processors.kafka.pubsub.PublishKafka_2_6")
@InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED)
@DynamicProperty(name = "The name of a Kafka configuration property.", value =
"The value of a given Kafka configuration property.",
description = "These properties will be added on the Kafka configuration
after loading any provided configuration properties."
diff --git
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/record/sink/kafka/KafkaRecordSink_1_0.java
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/record/sink/kafka/KafkaRecordSink_1_0.java
index a7d602baa3..d4efcfbca5 100644
---
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/record/sink/kafka/KafkaRecordSink_1_0.java
+++
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/record/sink/kafka/KafkaRecordSink_1_0.java
@@ -24,6 +24,7 @@ import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.ByteArraySerializer;
import org.apache.nifi.annotation.behavior.DynamicProperty;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
+import org.apache.nifi.annotation.documentation.DeprecationNotice;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnDisabled;
import org.apache.nifi.annotation.lifecycle.OnEnabled;
@@ -66,6 +67,7 @@ import java.util.concurrent.TimeoutException;
@Tags({"kafka", "record", "sink"})
@CapabilityDescription("Provides a service to write records to a Kafka 1.x
topic.")
+@DeprecationNotice(classNames =
"org.apache.nifi.record.sink.kafka.KafkaRecordSink_2_6")
@DynamicProperty(name = "The name of a Kafka configuration property.", value =
"The value of a given Kafka configuration property.",
description = "These properties will be added on the Kafka
configuration after loading any provided configuration properties."
+ " In the event a dynamic property represents a property that
was already set, its value will be ignored and WARN message logged."
