Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-15 22:45:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-13172 Deprecated nifi-kafka-connect components

Browse Source 
This closes #8803

Signed-off-by: David Handermann <exceptionfactory@apache.org>
This commit is contained in:
Joseph Witt 2024-05-09 17:01:25 -07:00 committed by exceptionfactory
parent 99603eb6b8
commit cf199a6b8b
No known key found for this signature in database
GPG Key ID: 29B6A52D2AAE8DBA
5 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nifi-external/nifi-kafka-connect/README.md
View File

@ -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

4
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkConnector.java
View File

@ -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;

4
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkTask.java
View File

@ -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);

4
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceConnector.java
View File

@ -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;

4
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceTask.java
View File

@ -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;