Supported NiFi controller services
This release is based on Apache NiFi versions 1.28 and 2.0, and includes a set of controller services. Most controller services included these NiFi versions are supported by Cloudera.
To ensure optimal performance and reliable support, it is crucial to use only supported controller services and avoid deploying unsupported ones in production environments.
Additional controller services are developed and tested by the community but are not officially supported by Cloudera. Controller services may be excluded for various reasons, including insufficient reliability, incomplete test coverage, community declaration of non-production readiness, or deviations from Cloudera best practices.
By adhering to the above guidelines, you can maintain stable and reliable workflows in your production environments.
NiFi 1.28
| AccumuloService | ImpalaConnectionPool |
| ActionHandlerLookup | IPFIXReader |
| ActiveMQJMSConnectionFactoryProvider | IPLookupService |
| ADLSCredentialsControllerService | JASN1Reader |
| ADLSCredentialsControllerServiceLookup | JiraRecordSink |
| ADLSIDBrokerCloudCredentialsProviderControllerService | JMSConnectionFactoryProvider |
| AlertHandler | JndiJmsConnectionFactoryProvider |
| AmazonGlueSchemaRegistry | JsonConfigBasedBoxClientService |
| AvroReader | JsonPathReader |
| AvroRecordSetWriter | JsonRecordSetWriter |
| AvroSchemaRegistry | JsonTreeReader |
| AWSCredentialsProviderControllerService | KafkaRecordSink_1_0 |
| AWSIDBrokerCloudCredentialsProviderControllerService | KafkaRecordSink_2_0 |
| AzureBlobIDBrokerCloudCredentialsProviderControllerService | KafkaRecordSink_2_6 |
| AzureCosmosDBClientService | KerberosKeytabUserService |
| AzureEventHubRecordSink | KerberosPasswordUserService |
| AzureServiceBusJMSConnectionFactoryProvider | KerberosTicketCacheUserService |
| AzureStorageCredentialsControllerService | KeytabCredentialsService |
| AzureStorageCredentialsControllerService_v12 | KuduLookupService |
| AzureStorageCredentialsControllerServiceLookup | LoggingRecordSink |
| AzureStorageCredentialsControllerServiceLookup_v12 | LogHandler |
| CassandraDistributedMapCache | MongoDBControllerService |
| CassandraSessionProvider | MongoDBLookupService |
| CdpCredentialsProviderControllerService | ParquetReader |
| CdpOauth2AccessTokenProviderControllerService | ParquetRecordSetWriter |
| CEFReader | PostgreSQLConnectionPool |
| CiscoEmblemSyslogMessageReader | PrometheusRecordSink |
| ClouderaHiveConnectionPool | ProtobufReader |
| ClouderaSchemaRegistry | RabbitMQJMSConnectionFactoryProvider |
| CMLLookupService | ReaderLookup |
| ConfluentSchemaRegistry | RecordSetWriterLookup |
| CouchbaseClusterService | RecordSinkHandler |
| CouchbaseKeyValueLookupService | RecordSinkServiceLookup |
| CouchbaseMapCacheClient | RedisConnectionPoolService |
| CouchbaseRecordLookupService | RedisDistributedMapCacheClientService |
| CSVReader | RedshiftConnectionPool |
| CSVRecordLookupService | RestLookupService |
| CSVRecordSetWriter | ScriptedActionHandler |
| DatabaseRecordLookupService | ScriptedLookupService |
| DatabaseRecordSink | ScriptedReader |
| DatabaseTableSchemaRegistry | ScriptedRecordSetWriter |
| DBCPConnectionPool | ScriptedRecordSink |
| DBCPConnectionPoolLookup | ScriptedRulesEngine |
| DistributedMapCacheClientService | SimpleDatabaseLookupService |
| DistributedMapCacheLookupService | SimpleKeyValueLookupService |
| DistributedMapCacheServer | SimpleRedisDistributedMapCacheClientService |
| DistributedSetCacheClientService | SimpleScriptedLookupService |
| DistributedSetCacheServer | SiteToSiteReportingRecordSink |
| EasyRulesEngineProvider | SmbjClientProviderService |
| EasyRulesEngineService | SnowflakeComputingConnectionPool |
| EBCDICRecordReader [Technical Preview] | StandardAsanaClientProviderService |
| ElasticSearchClientServiceImpl | StandardAzureCredentialsControllerService |
| ElasticSearchLookupService | StandardDropboxCredentialService |
| ElasticSearchStringLookupService | StandardFileResourceService |
| EmailRecordSink | StandardHashiCorpVaultClientService |
| EmbeddedHazelcastCacheManager | StandardHttpContextMap |
| ExcelReader | StandardJsonSchemaRegistry [Technical Preview] |
| ExpressionHandler | StandardOauth2AccessTokenProvider |
| ExternalHazelcastCacheManager | StandardPGPPrivateKeyService |
| FreeFormTextRecordSetWriter | StandardPGPPublicKeyService |
| GCPCredentialsControllerService | StandardPrivateKeyService |
| GrokReader | StandardProxyConfigurationService |
| HadoopCatalogService | StandardRestrictedSSLContextService |
| HadoopDBCPConnectionPool | StandardS3EncryptionService |
| HazelcastMapCacheClient | StandardSnowflakeIngestManagerProviderService |
| HBase_1_1_2_ClientMapCacheService | StandardSSLContextService |
| HBase_1_1_2_ClientService | StandardWebClientServiceProvider |
| HBase_1_1_2_ListLookupService | Syslog5424Reader |
| HBase_1_1_2_RecordLookupService | SyslogReader |
| HBase_2_ClientMapCacheService | UDPEventRecordSink |
| HBase_2_ClientService | VolatileSchemaCache |
| HBase_2_RecordLookupService | WindowsEventLogReader |
| Hive3ConnectionPool | XMLReader |
| HiveCatalogService | XMLRecordSetWriter |
| HiveConnectionPool | YamlTreeReader |
| HortonworksSchemaRegistry | ZendeskRecordSink |
NiFi 2.0
| AccumuloService | IPLookupService |
| ActiveMQJMSConnectionFactoryProvider | JASN1Reader |
| ADLSCredentialsControllerService | JiraRecordSink |
| ADLSCredentialsControllerServiceLookup | JMSConnectionFactoryProvider |
| ADLSIDBrokerCloudCredentialsProviderControllerService | JndiJmsConnectionFactoryProvider |
| AmazonGlueSchemaRegistry | JsonConfigBasedBoxClientService |
| ApicurioSchemaRegistry | JsonPathReader |
| AvroReader | JsonRecordSetWriter |
| AvroRecordSetWriter | JsonTreeReader |
| AvroSchemaRegistry | KafkaRecordSink_2_6 |
| AWSCredentialsProviderControllerService | KerberosKeytabUserService |
| AWSIDBrokerCloudCredentialsProviderControllerService | KerberosPasswordUserService |
| AzureBlobIDBrokerCloudCredentialsProviderControllerService | KerberosTicketCacheUserService |
| AzureCosmosDBClientService | KeytabCredentialsService |
| AzureEventHubRecordSink | KuduLookupService |
| AzureServiceBusJMSConnectionFactoryProvider | LoggingRecordSink |
| AzureStorageCredentialsControllerService_v12 | MongoDBControllerService |
| AzureStorageCredentialsControllerServiceLookup_v12 | MongoDBLookupService |
| CassandraDistributedMapCache | ParquetReader |
| CassandraSessionProvider | ParquetRecordSetWriter |
| CdpCredentialsProviderControllerService | PostgreSQLConnectionPool |
| CdpOauth2AccessTokenProviderControllerService | PrometheusRecordSink |
| CEFReader | ProxyPLC4XConnectionPool [Technical Preview] |
| CiscoEmblemSyslogMessageReader | RabbitMQJMSConnectionFactoryProvider |
| ClouderaHiveConnectionPool | ReaderLookup |
| ClouderaSchemaRegistry | RecordSetWriterLookup |
| CMLLookupService | RecordSinkServiceLookup |
| ConfluentEncodedSchemaReferenceReader | RedisConnectionPoolService |
| ConfluentEncodedSchemaReferenceWriter | RedisDistributedMapCacheClientService |
| ConfluentSchemaRegistry | RedshiftConnectionPool |
| CouchbaseClusterService | RestLookupService |
| CouchbaseKeyValueLookupService | ScriptedLookupService |
| CouchbaseMapCacheClient | ScriptedReader |
| CouchbaseRecordLookupService | ScriptedRecordSetWriter |
| CSVReader | ScriptedRecordSink |
| CSVRecordLookupService | SimpleDatabaseLookupService |
| CSVRecordSetWriter | SimpleKeyValueLookupService |
| DatabaseRecordLookupService | SimpleRedisDistributedMapCacheClientService |
| DatabaseRecordSink | SimpleScriptedLookupService |
| DatabaseTableSchemaRegistry | SiteToSiteReportingRecordSink |
| DBCPConnectionPool | SlackRecordSink |
| DBCPConnectionPoolLookup | SmbjClientProviderService |
| DistributedMapCacheClientService | SnowflakeComputingConnectionPool |
| DistributedMapCacheLookupService | StandardAsanaClientProviderService |
| DistributedMapCacheServer | StandardAzureCredentialsControllerService |
| DistributedSetCacheClientService | StandardDropboxCredentialService |
| DistributedSetCacheServer | StandardFileResourceService |
| EBCDICRecordReader [Technical Preview] | StandardHashiCorpVaultClientService |
| ElasticSearchClientServiceImpl | StandardHttpContextMap |
| ElasticSearchLookupService | StandardJsonSchemaRegistry [Technical Preview] |
| ElasticSearchStringLookupService | StandardOauth2AccessTokenProvider |
| EmailRecordSink | StandardPGPPrivateKeyService |
| EmbeddedHazelcastCacheManager | StandardPGPPublicKeyService |
| ExcelReader | StandardPLC4XConnectionPool [Technical Preview] |
| ExternalHazelcastCacheManager | StandardPrivateKeyService |
| FreeFormTextRecordSetWriter | StandardProxyConfigurationService |
| GCPCredentialsControllerService | StandardRestrictedSSLContextService |
| GCSFileResourceService | StandardS3EncryptionService |
| GenericPLC4XConnectionPool [Technical Preview] | StandardSnowflakeIngestManagerProviderService |
| GrokReader | StandardSSLContextService |
| HadoopCatalogService | StandardWebClientServiceProvider |
| HadoopDBCPConnectionPool | Syslog5424Reader |
| HazelcastMapCacheClient | SyslogReader |
| HBase_2_ClientMapCacheService | UDPEventRecordSink |
| HBase_2_ClientService | VolatileSchemaCache |
| HBase_2_RecordLookupService | WindowsEventLogReader |
| Hive3ConnectionPool | XMLReader |
| HiveCatalogService | XMLRecordSetWriter |
| ImpalaConnectionPool | YamlTreeReader |
| IPFIXReader | ZendeskRecordSink |
