Supported NiFi controller services
Learn about the Apache NiFi controller services supported by Cloudera that you can use with Cloudera DataFlow.
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 features in your production environments.
NiFi 1.25
| AccumuloService | ImpalaConnectionPool |
| ActionHandlerLookup | IPFIXReader |
| ActiveMQJMSConnectionFactoryProvider | IPLookupService |
| ADLSCredentialsControllerService | JASN1Reader |
| ADLSCredentialsControllerServiceLookup | JiraRecordSink |
| ADLSIDBrokerCloudCredentialsProviderControllerService | JMSConnectionFactoryProvider |
| AlertHandler | JndiJmsConnectionFactoryProvider |
| AmazonGlueSchemaRegistry | JsonConfigBasedBoxClientService |
| AvroReader | JsonPathReader |
| AvroRecordSetWriter | JsonRecordSetWriter |
| AvroSchemaRegistry | JsonTreeReader |
| AWSCredentialsProviderControllerService | |
| AWSIDBrokerCloudCredentialsProviderControllerService | |
| 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 | RabbitMQJMSConnectionFactoryProvider |
| ClouderaSchemaRegistry | ReaderLookup |
| CMLLookupService | RecordSetWriterLookup |
| ConfluentSchemaRegistry | RecordSinkHandler |
| CouchbaseClusterService | RecordSinkServiceLookup |
| CouchbaseKeyValueLookupService | RedisConnectionPoolService |
| CouchbaseMapCacheClient | RedisDistributedMapCacheClientService |
| CouchbaseRecordLookupService | RedshiftConnectionPool |
| CSVReader | RestLookupService |
| CSVRecordLookupService | ScriptedActionHandler |
| CSVRecordSetWriter | ScriptedLookupService |
| DatabaseRecordLookupService | ScriptedReader |
| DatabaseRecordSink | ScriptedRecordSetWriter |
| DatabaseTableSchemaRegistry | ScriptedRecordSink |
| DBCPConnectionPool | ScriptedRulesEngine |
| DBCPConnectionPoolLookup | SimpleDatabaseLookupService |
| DistributedMapCacheClientService | SimpleKeyValueLookupService |
| DistributedMapCacheLookupService | SimpleRedisDistributedMapCacheClientService |
| DistributedMapCacheServer | SimpleScriptedLookupService |
| DistributedSetCacheClientService | SiteToSiteReportingRecordSink |
| DistributedSetCacheServer | SmbjClientProviderService |
| SnowflakeComputingConnectionPool | |
| StandardAsanaClientProviderService | |
| EBCDICRecordReader [Technical Preview] | StandardAzureCredentialsControllerService |
| ElasticSearchClientServiceImpl | StandardDropboxCredentialService |
| ElasticSearchLookupService | StandardFileResourceService |
| ElasticSearchStringLookupService | StandardHashiCorpVaultClientService |
| EmailRecordSink | StandardHttpContextMap |
| EmbeddedHazelcastCacheManager | StandardJsonSchemaRegistry [Technical Preview] |
| ExcelReader | StandardOauth2AccessTokenProvider |
| ExpressionHandler | StandardPGPPrivateKeyService |
| ExternalHazelcastCacheManager | StandardPGPPublicKeyService |
| FreeFormTextRecordSetWriter | StandardPrivateKeyService |
| GCPCredentialsControllerService | StandardProxyConfigurationService |
| GrokReader | StandardRestrictedSSLContextService |
| HadoopCatalogService | StandardS3EncryptionService |
| HadoopDBCPConnectionPool | StandardSnowflakeIngestManagerProviderService |
| HazelcastMapCacheClient | StandardSSLContextService |
| HBase_1_1_2_ClientMapCacheService | StandardWebClientServiceProvider |
| HBase_1_1_2_ClientService | Syslog5424Reader |
| HBase_1_1_2_ListLookupService | SyslogReader |
| HBase_1_1_2_RecordLookupService | UDPEventRecordSink |
| HBase_2_ClientMapCacheService | VolatileSchemaCache |
| HBase_2_ClientService | WindowsEventLogReader |
| HBase_2_RecordLookupService | XMLReader |
| Hive3ConnectionPool | XMLRecordSetWriter |
| HiveCatalogService | YamlTreeReader |
| ZendeskRecordSink | |
| HortonworksSchemaRegistry |
NiFi 2.0 [Technical Preview]
| 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 |
