This is an automated email from the ASF dual-hosted git repository.
exceptionfactory 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 411e179af8 NIFI-14270 Added Tags Annotation to Kafka3ConnectionService
(#9883)
411e179af8 is described below
commit 411e179af8953c7208d1d31199c432a30c2f7a0c
Author: greyp9 <[email protected]>
AuthorDate: Fri Apr 18 10:08:15 2025 -0400
NIFI-14270 Added Tags Annotation to Kafka3ConnectionService (#9883)
Signed-off-by: David Handermann <[email protected]>
---
.../java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-service/src/main/java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-service/src/main/java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java
index 17932b0ec5..b9ee5ddce5 100644
---
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-service/src/main/java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java
+++
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-service/src/main/java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java
@@ -29,6 +29,7 @@ import org.apache.kafka.common.security.auth.SecurityProtocol;
import org.apache.kafka.common.serialization.ByteArrayDeserializer;
import org.apache.nifi.annotation.behavior.DynamicProperty;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
+import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnEnabled;
import org.apache.nifi.components.ConfigVerificationResult;
import org.apache.nifi.components.PropertyDescriptor;
@@ -81,6 +82,7 @@ import static
org.apache.nifi.kafka.shared.property.KafkaClientProperty.SSL_TRUS
import static
org.apache.nifi.kafka.shared.property.KafkaClientProperty.SSL_TRUSTSTORE_PASSWORD;
import static
org.apache.nifi.kafka.shared.property.KafkaClientProperty.SSL_TRUSTSTORE_TYPE;
+@Tags({"Apache", "Kafka", "Message", "Publish", "Consume"})
@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."
