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