diff --git a/nifi-external/nifi-kafka-connect/README.md b/nifi-external/nifi-kafka-connect/README.md
index c927b856c5..57f63dd38e 100644
--- a/nifi-external/nifi-kafka-connect/README.md
+++ b/nifi-external/nifi-kafka-connect/README.md
@@ -15,6 +15,9 @@
 
 # Introduction
 
+Please note as of Apache NiFi 1.27.0 release this capability is deprecated and will be removed
+in the NiFi 2.x codebase.
+
 Apache NiFi is a very powerful tool for authoring and running dataflows. It provides many capabilities that are necessary for large-scale
 enterprise deployments, such as data persistence and resilience, data lineage and traceability, and multi-tenancy. This, however, requires
 that an administrator be responsible for ensuring that this process is running and operational. And generally, adding more capabilities
diff --git a/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkConnector.java b/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkConnector.java
index d830c991ad..dae3961665 100644
--- a/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkConnector.java
+++ b/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkConnector.java
@@ -26,6 +26,10 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+/**
+ * NiFi Kafka Connect is Deprecated and will be removed in a later release
+ */
+@Deprecated
 public class StatelessNiFiSinkConnector extends SinkConnector {
 
     private Map<String, String> properties;
diff --git a/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkTask.java b/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkTask.java
index 8cf38e7966..01d731c0e0 100644
--- a/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkTask.java
+++ b/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkTask.java
@@ -43,6 +43,10 @@ import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import java.util.regex.Pattern;
 
+/**
+ * NiFi Kafka Connect is Deprecated and will be removed in a later release
+ */
+@Deprecated
 public class StatelessNiFiSinkTask extends SinkTask {
     private static final Logger logger = LoggerFactory.getLogger(StatelessNiFiSinkTask.class);
 
diff --git a/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceConnector.java b/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceConnector.java
index 2e489513ec..8fc53f187c 100644
--- a/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceConnector.java
+++ b/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceConnector.java
@@ -27,6 +27,10 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+/**
+ * NiFi Kafka Connect is Deprecated and will be removed in a later release
+ */
+@Deprecated
 public class StatelessNiFiSourceConnector extends SourceConnector {
 
     private StatelessNiFiSourceConfig config;
diff --git a/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceTask.java b/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceTask.java
index 54e974d607..aac401e15a 100644
--- a/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceTask.java
+++ b/nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceTask.java
@@ -44,6 +44,10 @@ import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.regex.Pattern;
 
+/**
+ * NiFi Kafka Connect is Deprecated and will be removed in a later release
+ */
+@Deprecated
 public class StatelessNiFiSourceTask extends SourceTask {
     private static final Logger logger = LoggerFactory.getLogger(StatelessNiFiSourceTask.class);
     private static final long FAILURE_YIELD_MILLIS = 1000L;