Skip to content

Commit 411e179

Browse files
authored
NIFI-14270 Added Tags Annotation to Kafka3ConnectionService (#9883)
Signed-off-by: David Handermann <[email protected]>
1 parent 2559fc1 commit 411e179

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-service/src/main/java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java

+2
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import org.apache.kafka.common.serialization.ByteArrayDeserializer;
3030
import org.apache.nifi.annotation.behavior.DynamicProperty;
3131
import org.apache.nifi.annotation.documentation.CapabilityDescription;
32+
import org.apache.nifi.annotation.documentation.Tags;
3233
import org.apache.nifi.annotation.lifecycle.OnEnabled;
3334
import org.apache.nifi.components.ConfigVerificationResult;
3435
import org.apache.nifi.components.PropertyDescriptor;
@@ -81,6 +82,7 @@
8182
import static org.apache.nifi.kafka.shared.property.KafkaClientProperty.SSL_TRUSTSTORE_PASSWORD;
8283
import static org.apache.nifi.kafka.shared.property.KafkaClientProperty.SSL_TRUSTSTORE_TYPE;
8384

85+
@Tags({"Apache", "Kafka", "Message", "Publish", "Consume"})
8486
@DynamicProperty(name = "The name of a Kafka configuration property.", value = "The value of a given Kafka configuration property.",
8587
description = "These properties will be added on the Kafka configuration after loading any provided configuration properties."
8688
+ " In the event a dynamic property represents a property that was already set, its value will be ignored and WARN message logged."

0 commit comments

Comments
 (0)