GetSolr
PutSolrContentStream
PutSolrRecord
QuerySolr
Apache NiFi supports a large number of extension components for integrating with a variety of products and services. Over the course of product development, some services reach end of life and some components no longer represent the best implementation approach.
Apache NiFi 1.18.0 and following include deprecation logging written to nifi-deprecation.log indicating runtime references to deprecated components and features. Generated documentation and runtime logging provide the most accurate information on deprecated components and features for a given deployment.
| Name | Type | Version | Alternatives | Removed |
|---|---|---|---|---|
| ActionHandlerLookup | Controller Service | 1.24.0 | ||
| AlertHandler | Controller Service | 1.24.0 | ||
| AmbariReportingTask | Reporting Task | 1.21.0 | ||
| Base64EncodeContent | Processor | 1.20.0 | EncodeContent | |
| CassandraSessionProvider | Controller Service | 1.26.0 | ||
| CompareFuzzyHash | Processor | 1.24.0 | ||
| ConsumeEWS | Processor | 1.20.0 | ||
| ConsumeKafka_1_0 | Processor | 1.21.0 | ConsumeKafka + Kafka3ConnectionService | |
| ConsumeKafka_2_0 | Processor | 1.21.0 | ConsumeKafka + Kafka3ConnectionService | |
| ConsumeKafka_2_6 | Processor | 1.29.0 | ConsumeKafka + Kafka3ConnectionService | |
| ConsumeKafkaRecord_1_0 | Processor | 1.21.0 | ConsumeKafka + Kafka3ConnectionService | |
| ConsumeKafkaRecord_2_0 | Processor | 1.21.0 | ConsumeKafka + Kafka3ConnectionService | |
| ConsumeKafkaRecord_2_6 | Processor | 1.29.0 | ConsumeKafka + Kafka3ConnectionService | |
| ConvertAvroToJSON | Processor | 1.26.0 | ConvertRecord | |
| ConvertExcelToCSVProcessor | Processor | 1.24.0 | ExcelReader | |
| ConvertJSONToSql | Processor | 1.28.0 | ||
| CouchbaseClusterService | Controller Service | 1.27.0 | ||
| CouchbaseKeyValueLookupService | Controller Service | 1.27.0 | ||
| CouchbaseMapCacheClient | Controller Service | 1.27.0 | ||
| CouchbaseRecordLookupService | Controller Service | 1.27.0 | ||
| CryptographicHashAttribute | Processor | 1.21.0 | UpdateAttribute with expression language hash() function | |
| DecryptContent | Processor | 1.28.0 | ||
| DecryptContentCompatibility | Processor | 1.28.0 | ||
| DeleteHBaseCells | Processor | 1.29.0 | ||
| DeleteHBaseRow | Processor | 1.29.0 | ||
| DeleteRethinkDB | Processor | 1.23.0 | ||
| DatadogReportingTask | Reporting Task | 1.27.0 | ||
| DistributedMapCacheClientService | Controller Service | 2.0.0-M4 | MapCacheClientService | |
| DistributedMapCacheServer | Controller Service | 2.0.0-M4 | MapCacheServer | |
| EncryptContent | Processor | 1.24.0 | EncryptContentAge or EncryptContentPGP | |
| ExecuteFlumeSink | Processor | 1.19.0 | ||
| ExecuteFlumeSource | Processor | 1.19.0 | ||
| ExecuteInfluxDBQuery | Processor | 1.25.0 | InfluxData nifi-influxdb-bundle | |
| ExecuteStateless | Processor | 2.0.0-M2 | Stateless Process Groups | |
| ExpressionHandler | Controller Service | 1.24.0 | ||
| ExtractCCDAAttributes | Processor | 1.20.0 | ||
| ExtractTNEFAttachments | Processor | 1.28.0 | ||
| FetchElasticsearchHttp | Processor | 1.16.0 | GetElasticsearch | |
| FetchHBaseRow | Processor | 1.29.0 | ||
| FuzzyHashContent | Processor | 1.24.0 | ||
| GetAzureQueueStorage | Processor | 1.22.0 | GetAzureQueueStorage_v12 | |
| GetCouchbaseKey | Processor | 1.27.0 | ||
| GetHBaseRow | Processor | 1.29.0 | ||
| GetHTMLElement | Processor | 1.24.0 | ||
| GetHTTP | Processor | 1.9.0 | InvokeHTTP | |
| GetIgniteCache | Processor | 1.22.0 | ||
| GetJMSQueue | Processor | 1.3.0 | ConsumeJMS | |
| GetJMSTopic | Processor | 1.3.0 | ConsumeJMS | |
| GetRethinkDB | Processor | 1.23.0 | ||
GetSolr | Processor | 1.26.0 | ||
| GetTCP | Processor | 1.24.0 | ||
| GetTwitter | Processor | 1.17.0 | ConsumeTwitter | |
| GraphiteMetricReporterService | Controller Service | 1.24.0 | ||
| DeleteAzureBlobStorage | Processor | 1.19.0 | DeleteAzureBlobStorage_v12 | |
| ExecuteSparkInteractive | Processor | 1.26.0 | ||
| FetchAzureBlobStorage | Processor | 1.19.0 | FetchAzureBlobStorage_v12 | |
| HadoopCatalogService | Controller Service | 1.29.0 | ||
| HiveCatalogService | Controller Service | 1.29.0 | ||
| HiveConnectionPool | Controller Service | 1.19.0 | ||
| Hive_1_1ConnectionPool | Controller Service | 1.19.0 | ||
| Hive3ConnectionPool | Controller Service | 1.26.0 | ||
| HashAttribute | Processor | 1.21.0 | CryptographicHashAttribute | |
| HashContent | Processor | 1.8.0 | CryptographicHashContent | |
| HortonworksSchemaRegistry | Controller Service | 1.20.0 | ||
| HBase_2_ClientMapCacheService | Controller Service | 1.29.0 | ||
| HBase_2_ClientService | Controller Service | 1.29.0 | ||
| HBase_2_LIstLookupService | Controller Service | 1.29.0 | ||
| HBase_2_RecordLookupService | Controller Service | 1.29.0 | ||
| InvokeAWSGatewayApi | Processor | 1.27.0 | ||
| InvokeGRPC | Processor | 1.24.0 | ||
| JdbcCatalogService | Controller Service | 1.29.0 | ||
| KafkaRecordSink_1_0 | Controller Service | 1.21.0 | ||
| KafkaRecordSink_2_0 | Controller Service | 1.21.0 | ||
| KafkaRecordSink_2_6 | Controller Service | 1.29 | ||
| KuduLookupService | Controller Service | 1.28.0 | ||
| ListenBeats | Processor | 1.28.0 | ||
| ListenGRPC | Processor | 1.24.0 | ||
| ListenRELP | Processor | 1.28.0 | ListenOTLP | |
| ListenSMTP | Processor | 1.28.0 | ||
| ListenTCPRecord | Processor | 1.28.0 | ListenTCP | |
| ListAzureBlobStorage | Processor | 1.19.0 | ListAzureBlobStorage_v12 | |
| ListHBaseRegions | Processor | 1.29.0 | ||
| LivySessionController | Controller Service | 1.26.0 | ||
| LogHandler | Processor | 1.24.0 | ||
| MetricsReportingTask | Reporting Task | 1.24.0 | ||
| ModifyHTMLElement | Processor | 1.24.0 | ||
| Neo4JCypher3ClientService | Controller Service | 1.16.0 | Neo4JCypherClientService | |
| OAuth2TokenProviderImpl | Controller Service | 1.16.0 | StandardOauth2AccessTokenProvider | |
| Controller Service | 1.21.0 | |||
| ParseCEF | Processor | 1.28.0 | CEFReader | |
| PostHTTP | Processor | 1.9.0 | InvokeHTTP | |
| PostSlack | Processor | 1.25.0 | PublishSlack | |
| PrometheusReportingTask | Reporting Task | 1.28.0 | REST API Metrics | |
| PrometheusRecordSink | Controller Service | 1.28.0 | REST API Metrics | |
| PutCassandraQL | Processor | 1.26.0 | ||
| PutCassandraRecord | Processor | 1.26.0 | ||
| PutCouchbaseKey | Processor | 1.27.0 | ||
| PublishKafka_1_0 | Processor | 1.21.0 | PublishKafka + Kafka3ConnectionService | |
| PublishKafka_2_0 | Processor | 1.21.0 | PublishKafka + Kafka3ConnectionService | |
| PublishKafka_2_6 | Processor | 1.29.0 | PublishKafka + Kafka3ConnectionService | |
| PublishKafkaRecord_1_0 | Processor | 1.21.0 | PublishKafka + Kafka3ConnectionService | |
| PublishKafkaRecord_2_0 | Processor | 1.21.0 | PublishKafka + Kafka3ConnectionService | |
| PublishKafkaRecord_2_6 | Processor | 1.29.0 | PublishKafka + Kafka3ConnectionService | |
| PutAzureBlobStorage | Processor | 1.19.0 | PutAzureBlobStorage_v12 | |
| PutAzureQueueStorage | Processor | 1.22.0 | PutAzureQueueStorage_v12 | |
| PutBigQueryBatch | Processor | 1.18.0 | PutBigQuery | |
| PutBigQueryStreaming | Processor | 1.18.0 | PutBigQuery | |
| PutElasticsearchHttp | Processor | 1.16.0 | PutElasticsearchJson | |
| PutElasticsearchHttpRecord | Processor | 1.16.0 | PutElasticsearchRecord | |
| PutHBaseCell | Processor | 1.29.0 | ||
| PutHBaseJSON | Processor | 1.29.0 | ||
| PutHBaseRecord | Processor | 1.29.0 | ||
| PutHiveQL | Processor | 1.19.0 | PutHive3QL | |
| PutHive_1_1QL | Processor | 1.19.0 | PutHive3QL | |
| PutHiveStreaming | Processor | 1.19.0 | PutHive3Streaming | |
| PutHive3QL | Processor | 1.26.0 | ||
| PutHive3Streaming | Processor | 1.26.0 | ||
| PutHTMLElement | Processor | 1.24.0 | ||
| PutIceberg | Processor | 1.29.0 | ||
| PutIgniteCache | Processor | 1.22.0 | ||
| PutInfluxDB | Processor | 1.25.0 | InfluxData nifi-influxdb-bundle | |
| PutJMS | Processor | 1.3.0 | PublishJMS | |
| PutKudu | Processor | 1.28.0 | ||
| PutORC | Processor | 1.26.0 | ||
| PutRethinkDB | Processor | 1.23.0 | ||
| PutRiemann | Processor | 1.24.0 | ||
| PutSlack | Processor | 1.25.0 | PublishSlack | |
PutSolrContentStream | Processor | 1.26.0 | ||
PutSolrRecord | Processor | 1.26.0 | ||
| QueryCassandra | Processor | 1.26.0 | ||
| QueryDNS | Processor | 1.28.0 | ||
| QueryElasticsearchHttp | Processor | 1.15.0 | PaginatedJsonQueryElasticsearch | |
QuerySolr | Processor | 1.26.0 | ||
| QueryWhois | Processor | 1.28.0 | ||
| ReportLineageToAtlas | Reporting Task | 1.26.0 | ||
| RecordSinkHandler | Controller Service | 1.24.0 | ||
| ScanHBase | Processor | 1.29.0 | ||
| ScrollElasticsearchHttp | Processor | 1.15.0 | SearchElasticsearch | |
| SelectHiveQL | Processor | 1.19.0 | SelectHive3QL | |
| SelectHive_1_1QL | Processor | 1.19.0 | SelectHive3QL | |
| SelectHive3QL | Processor | 1.26.0 | ||
| SpringContextProcessor | Processor | 1.24.0 | ||
| StandardGangliaReporter | Reporting Task | 1.28.0 | REST API Metrics | |
| TriggerHiveMetaStoreEvent | Processor | 1.26.0 | ||
| UpdateHiveTable | Processor | 1.19.0 | UpdateHive3Table | |
| UpdateHive_1_1Table | Processor | 1.19.0 | UpdateHive3Table | |
| UpdateHive3Table | Controller Service | 1.26.0 | ||
| YandexTranslate | Processor | 1.28.0 |
| Class | Feature | Version | Alternatives | Deprecated | Removed |
|---|---|---|---|---|---|
| org.apache.nifi.toolkit.encryptconfig.EncryptConfigMain | encrypt-config command for application properties | 1.26.1 | No alternatives | ||
| org.apache.nifi.processor.ProcessContext | encrypt and decrypt Methods | 1.20.0 | No alternatives: new implementation required | ||
| org.apache.nifi.nar.hadoop.HDFSNarProvider | NAR Resource Retrieval | 1.17.0 | org.apache.nifi.flow.resource.hadoop.HDFSExternalResourceProvider | ||
| org.apache.nifi.processors.hadoop.ListHDFS | Distributed Cache Service Property | 1.9.0 | No alternatives: property no longer used | ||
| org.apache.nifi.provenance.PersistentProvenanceRepository | Provenance Repository | 1.8.0 | org.apache.nifi.provenance.WriteAheadProvenanceRepository | ||
| org.apache.nifi.serialization.RecordSetWriterFactory | createWriter Method without FlowFile | 1.10.0 | createWriter Method with FlowFile | ||
| org.apache.nifi.controller.repository.RocksDBFlowFileRepository | FlowFile Repository | 1.17.0 | org.apache.nifi.controller.repository.WriteAheadFlowFileRepository | ||
| org.apache.nifi.schemaregistry.services.SchemaRegistry | retrieveSchemaText Methods | 1.6.0 | retrieveSchema Method | ||
| org.apache.nifi.security.util.crypto.NiFiLegacyCipherProvider | Cipher Provider | 0.5.0 | org.apache.nifi.security.util.crypto.PBKDF2CipherProvider | ||
| org.apache.nifi.ssl.SSLContextService | createSSLContext Methods | 1.13.0 | createContext Method | ||
| org.apache.nifi.processors.standard.EncryptContent | PGP encryption and decryption properties | 1.19.0 | EncryptContentPGP and DecryptContentPGP Processors | ||
| org.apache.nifi.processors.standard.InvokeHTTP | Proxy Host and Port properties | 1.18.0 | Proxy Configuration Service Property | ||
| org.apache.nifi.registry.VariableRegistry | Variable Registry | 1.10.0 | Parameter Contexts | ||
| org.apache.nifi.controller.XmlFlowSynchronizer | XML Flow Configuration stored as flow.xml.gz | 1.16.0 | JSON Flow Configuration stored as flow.json.gz | ||
| org.apache.nifi.persistence.TemplateDeserializer | XML Flow Templates | 1.14.0 | JSON Flow Definitions | ||
| org.apache.nifi.processors.kafka.ConsumeKafka_2_6 and others | Standalone Kerberos and Kerberos Credentials Service Properties | 1.21.0 | Kerberos User Service property | ||
| org.apache.nifi.encrypt.PropertyEncryptionMethod | BCRYPT and SCRYPT algorithms along with variants supporting keys of 128 bits | 1.21.0 | NIFI_PBKDF2_AES_GCM_256 or NIFI_ARGON2_AES_GCM_256 | ||
| org.apache.nifi.toolkit.s2s.SiteToSiteCliMain | Site-to-Site Toolkit Sender and Receiver commands | 1.21.0 | No alternatives: custom implementation required | ||
| org.apache.nifi.toolkit.admin.NodeManagerTool and others | Admin Toolkit commands for notification and node management | 1.21.0 | The NiFi CLI toolkit and nifi.sh support node management commands | ||
| org.apache.nifi.processors.mongodb.PutMongo | Mongo URI property | 1.22.0 | MongoDBControllerService implementations | ||
| org.apache.nifi.processors.script.ExecuteScript | ECMAScript Script Engine supporting JavaScript with Nashorn | 1.22.0 | Groovy Script Engine | ||
| org.apache.nifi.processors.script.ExecuteScript | lua and ruby Script Engine options | 1.22.0 | Groovy Script Engine | ||
| org.apache.nifi.processors.script.ExecuteScript | Jython Script Engine | 1.24.0 | Groovy Script Engine or Native Python in 2.0.0 | ||
| org.apache.nifi.scheduling.SchedulingStrategy.EVENT_DRIVEN | Event Driven Scheduling Strategy | 1.24.0 | Timer Driven Scheduling Strategy | ||
| org.wali.MinimalLockingWriteAheadLog | Flow File Repository: Minimal Locking Write Ahead Log | 1.6.0 | Flow File Repository: Sequential Access Write Ahead Log | ||
| org.apache.nifi.bootstrap.NotificationServiceManager | Bootstrap Lifecycle Notifications for NiFi start and stop operations | 1.25.0 | No alternatives: Custom Reporting Task or external monitoring | ||
| org.apache.nifi.toolkit.tls.TlsToolkitMain | TLS Toolkit commands | 1.24.0 | External OpenSSL commands or other tools for certificate generation | ||
org.apache.nifi.kafka.connect.StatelessNiFiSinkConnector org.apache.nifi.kafka.connect.StatelessNiFiSinkTask org.apache.nifi.kafka.connect.StatelessNiFiSourceConnector org.apache.nifi.kafka.connect.StatelessNiFiSourceTask | NiFi Kafka Connector | 1.27.0 | A standalone component that allows a stateless NiFi flow to run inside of Kafka Connect. | ||
org.apache.nifi.web.security.configuration.Knox | Apache Knox SSO Authentication | 1.27.0 | OpenID Connect or SAML 2 for Single Sign-On | ||
org.apache.nifi.web.security.configuration.Kerberos | Kerberos SPNEGO Authentication | 1.27.0 | OpenID Connect or SAML 2 for Single Sign-On | ||
org.apache.nifi.controller.repository.crypto.EncryptedFileSystemRepository | Repository Encryption | 1.28.0 | Operating System or Cloud Provider Volume Encryption |