Supported NiFi controller services
Learn about the Apache NiFi controller services supported by Cloudera that you can use with Cloudera Data Flow.
Additional controller services are developed and tested by the Cloudera community but are not officially supported by Cloudera. Controller services are excluded for a variety of reasons, including insufficient reliability or incomplete test case coverage, declaration of non-production readiness by the community at large, and feature deviation from Cloudera best practices. Do not use these controller services in your production environments.
NiFi 1.28.1
| ActionHandlerLookup | ElasticSearchStringLookupService | PulsarClientJwtAuthenticationService |
| ActiveMQJMSConnectionFactoryProvider | EmailRecordSink | PulsarClientOauthAuthenticationService |
| ADLSCredentialsControllerService | EmbeddedHazelcastCacheManager | PulsarClientTlsAuthenticationService |
| ADLSCredentialsControllerServiceLookup | ExcelReader | RabbitMQJMSConnectionFactoryProvider |
| ADLSIDBrokerCloudCredentialsProviderControllerService | ExpressionHandler | ReaderLookup |
| AlertHandler | ExternalHazelcastCacheManager | RecordSetWriterLookup |
| AmazonGlueSchemaRegistry | FreeFormTextRecordSetWriter | RecordSinkHandler |
| AvroReader | GCPCredentialsControllerService | RecordSinkServiceLookup |
| AvroRecordSetWriter | GrokReader | RedisConnectionPoolService |
| AvroSchemaRegistry | HBase_1_1_2_ClientMapCacheService | RedisDistributedMapCacheClientService |
| AWSCredentialsProviderControllerService | HBase_1_1_2_ClientService | RedshiftConnectionPool |
| AWSIDBrokerCloudCredentialsProviderControllerService | HBase_1_1_2_ListLookupService | RestLookupService |
| AzureBlobIDBrokerCloudCredentialsProviderControllerService | HBase_1_1_2_RecordLookupService | ScriptedActionHandler |
| AzureCosmosDBClientService | HBase_2_ClientMapCacheService | ScriptedLookupService |
| AzureEventHubRecordSink | HBase_2_ClientService | ScriptedReader |
| AzureServiceBusJMSConnectionFactoryProvider | HBase_2_RecordLookupService | ScriptedRecordSetWriter |
| AzureStorageCredentialsControllerService | HadoopCatalogService | ScriptedRecordSink |
| AzureStorageCredentialsControllerServiceLookup | HadoopDBCPConnectionPool | ScriptedRulesEngine |
| AzureStorageCredentialsControllerServiceLookup_v12 | HazelcastMapCacheClient | SimpleDatabaseLookupService |
| AzureStorageCredentialsControllerService_v12 | Hive3ConnectionPool | SimpleKeyValueLookupService |
| CassandraDistributedMapCache | HiveCatalogService | SimpleRedisDistributedMapCacheClientService |
| CassandraSessionProvider | HiveConnectionPool | SimpleScriptedLookupService |
| CdpCredentialsProviderControllerService | HortonworksSchemaRegistry | SiteToSiteReportingRecordSink |
| CdpOauth2AccessTokenProviderControllerService | ImpalaConnectionPool | SmbjClientProviderService |
| CEFReader | IPLookupService | SnowflakeComputingConnectionPool |
| CiscoEmblemSyslogMessageReader | IPFIXReader | StandardAsanaClientProviderService |
| ClouderaHiveConnectionPool | JASN1Reader | StandardAzureCredentialsControllerService |
| ClouderaSchemaRegistry | JiraRecordSink | StandardDropboxCredentialService |
| CMLLookupService | JMSConnectionFactoryProvider | StandardFileResourceService |
| ConfluentSchemaRegistry | JndiJmsConnectionFactoryProvider | StandardHashiCorpVaultClientService |
| CouchbaseClusterService | JsonConfigBasedBoxClientService | StandardHttpContextMap |
| CouchbaseKeyValueLookupService | JsonPathReader | StandardJsonSchemaRegistry1 |
| CouchbaseMapCacheClient | JsonRecordSetWriter | StandardOauth2AccessTokenProvider |
| CouchbaseRecordLookupService | JsonTreeReader | StandardPGPPrivateKeyService |
| CSVReader | KafkaRecordSink_1_0 | StandardPGPPublicKeyService |
| CSVRecordLookupService | KafkaRecordSink_2_0 | StandardPrivateKeyService |
| CSVRecordSetWriter | KafkaRecordSink_2_6 | StandardProxyConfigurationService |
| DatabaseRecordLookupService | KerberosKeytabUserService | StandardPulsarClientService |
| DatabaseRecordSink | KerberosPasswordUserService | StandardRestrictedSSLContextService |
| DatabaseTableSchemaRegistry | KerberosTicketCacheUserService | StandardS3EncryptionService |
| DBCPConnectionPool | KeytabCredentialsService | StandardSnowflakeIngestManagerProviderService |
| DBCPConnectionPoolLookup | KuduLookupService | StandardSSLContextService |
| DistributedMapCacheClientService | LogHandler | StandardWebClientServiceProvider |
| DistributedMapCacheLookupService | LoggingRecordSink | Syslog5424Reader |
| DistributedMapCacheServer | MongoDBControllerService | SyslogReader |
| DistributedSetCacheClientService | MongoDBLookupService | UDPEventRecordSink |
| DistributedSetCacheServer | ParquetReader | VolatileSchemaCache |
| EasyRulesEngineProvider | ParquetRecordSetWriter | WindowsEventLogReader |
| EasyRulesEngineService | PostgreSQLConnectionPool | XMLReader |
| EBCDICRecordReader1 | PrometheusRecordSink | XMLRecordSetWriter |
| ElasticSearchClientServiceImpl | ProtobufReader | YamlTreeReader |
| ElasticSearchLookupService | PulsarClientAthenzAuthenticationService | ZendeskRecordSink |
NiFi 2.4
| AccumuloService | DistributedSetCacheClientService | ProxyPLC4XConnectionPool |
| ActiveMQJMSConnectionFactoryProvider | DistributedSetCacheServer | RabbitMQJMSConnectionFactoryProvider |
| ADLSCredentialsControllerService | EBCDICRecordReader1 | ReaderLookup |
| ADLSCredentialsControllerServiceLookup | ElasticSearchClientServiceImpl | RecordSetWriterLookup |
| ADLSIDBrokerCloudCredentialsProviderControllerService | ElasticSearchLookupService | RecordSinkServiceLookup |
| AmazonGlueSchemaRegistry | ElasticSearchStringLookupService | RedisConnectionPoolService |
| ApicurioSchemaRegistry | EmailRecordSink | RedisDistributedMapCacheClientService |
| AvroReader | EmbeddedHazelcastCacheManager | RedshiftConnectionPool |
| AvroRecordSetWriter | ExcelReader | RESTCatalogService |
| AvroSchemaRegistry | ExternalHazelcastCacheManager | RestLookupService |
| AWSCredentialsProviderControllerService | FreeFormTextRecordSetWriter | ScriptedLookupService |
| AWSIDBrokerCloudCredentialsProviderControllerService | GCPCredentialsControllerService | ScriptedReader |
| AzureBlobIDBrokerCloudCredentialsProviderControllerService | GCSFileResourceService | ScriptedRecordSetWriter |
| AzureCosmosDBClientService | GenericPLC4XConnectionPool | ScriptedRecordSink |
| AzureEventHubRecordSink | GrokReader | SimpleDatabaseLookupService |
| AzureServiceBusJMSConnectionFactoryProvider | HBase_2_ClientMapCacheService | SimpleKeyValueLookupService |
| AzureStorageCredentialsControllerServiceLookup_v12 | HBase_2_ClientService | SimpleRedisDistributedMapCacheClientService |
| AzureStorageCredentialsControllerService_v12 | HBase_2_RecordLookupService | SimpleScriptedLookupService |
| CassandraDistributedMapCache | HadoopCatalogService | SiteToSiteReportingRecordSink |
| CassandraSessionProvider | HadoopDBCPConnectionPool | SlackRecordSink |
| CdpCredentialsProviderControllerService | HazelcastMapCacheClient | SmbjClientProviderService |
| CdpOauth2AccessTokenProviderControllerService | Hive3ConnectionPool | SnowflakeComputingConnectionPool |
| CEFReader | HiveCatalogService | StandardAsanaClientProviderService |
| CiscoEmblemSyslogMessageReader | ImpalaConnectionPool | StandardAzureCredentialsControllerService |
| ClouderaAttributeSchemaReferenceReader | IPLookupService | StandardDatabaseDialectService |
| ClouderaAttributeSchemaReferenceWriter | IPFIXReader | StandardDropboxCredentialService |
| ClouderaEncodedSchemaReferenceReader | JASN1Reader | StandardFileResourceService |
| ClouderaEncodedSchemaReferenceWriter | JiraRecordSink | StandardHashiCorpVaultClientService |
| ClouderaHiveConnectionPool | JMSConnectionFactoryProvider | StandardHttpContextMap |
| ClouderaHiveConnectionPoolLookup | JndiJmsConnectionFactoryProvider | StandardJsonSchemaRegistry1 |
| ClouderaSchemaRegistry | JsonConfigBasedBoxClientService | StandardOauth2AccessTokenProvider |
| CMLLookupService | JsonPathReader | StandardPLC4XConnectionPool |
| ConfluentEncodedSchemaReferenceReader | JsonRecordSetWriter | StandardPGPPrivateKeyService |
| ConfluentEncodedSchemaReferenceWriter | JsonTreeReader | StandardPGPPublicKeyService |
| ConfluentSchemaRegistry | JWTBearerOAuth2AccessTokenProvider | StandardPrivateKeyService |
| CouchbaseClusterService | KafkaRecordSink_2_6 | StandardProxyConfigurationService |
| CouchbaseKeyValueLookupService | KerberosKeytabUserService | StandardRestrictedSSLContextService |
| CouchbaseMapCacheClient | KerberosPasswordUserService | StandardS3EncryptionService |
| CouchbaseRecordLookupService | KerberosTicketCacheUserService | StandardSnowflakeIngestManagerProviderService |
| CSVReader | KuduLookupService | StandardSSLContextService |
| CSVRecordLookupService | LoggingRecordSink | StandardWebClientServiceProvider |
| CSVRecordSetWriter | MongoDBControllerService | Syslog5424Reader |
| DatabaseRecordLookupService | MongoDBLookupService | SyslogReader |
| DatabaseRecordSink | ParquetReader | UDPEventRecordSink |
| DatabaseTableSchemaRegistry | ParquetRecordSetWriter | VolatileSchemaCache |
| DBCPConnectionPool | PEMEncodedSSLContextProvider | WindowsEventLogReader |
| DBCPConnectionPoolLookup | PhoenixThickConnectionPool | XMLReader |
| DeveloperBoxClientService | PhoenixThinConnectionPool | XMLRecordSetWriter |
| DistributedMapCacheClientService | PostgreSQLConnectionPool | YamlTreeReader |
| DistributedMapCacheLookupService | PrometheusRecordSink | ZendeskRecordSink |
| DistributedMapCacheServer |
1 Technical Preview
