Supported NiFi controller services

Learn about the controller services supported in Flow Management Data Hub clusters using Apache NiFi 1 or NiFi 2 in Cloudera DataFlow for Data Hub 7.3.1.400.

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.1 in Cloudera Flow Management 2.2.9.400

AccumuloService ElasticSearchClientServiceImpl PrometheusRecordSink
ActionHandlerLookup ElasticSearchLookupService ProtobufReader
ActiveMQJMSConnectionFactoryProvider ElasticSearchStringLookupService RabbitMQJMSConnectionFactoryProvider
ADLSCredentialsControllerService EmailRecordSink ReaderLookup
ADLSCredentialsControllerServiceLookup EmbeddedHazelcastCacheManager RecordSetWriterLookup
ADLSIDBrokerCloudCredentialsProviderControllerService ExcelReader RecordSinkHandler
AlertHandler ExpressionHandler RecordSinkServiceLookup
AmazonGlueSchemaRegistry ExternalHazelcastCacheManager RedisConnectionPoolService
AvroReader FreeFormTextRecordSetWriter RedisDistributedMapCacheClientService
AvroRecordSetWriter GCPCredentialsControllerService RedshiftConnectionPool
AvroSchemaRegistry GrokReader RestLookupService
AWSCredentialsProviderControllerService HadoopCatalogService ScriptedActionHandler
AWSIDBrokerCloudCredentialsProviderControllerService HadoopDBCPConnectionPool ScriptedLookupService
AzureBlobIDBrokerCloudCredentialsProviderControllerService HazelcastMapCacheClient ScriptedReader
AzureCosmosDBClientService HBase_1_1_2_ClientMapCacheService ScriptedRecordSetWriter
AzureEventHubRecordSink HBase_1_1_2_ClientService ScriptedRecordSink
AzureServiceBusJMSConnectionFactoryProvider HBase_1_1_2_ListLookupService ScriptedRulesEngine
AzureStorageCredentialsControllerService HBase_1_1_2_RecordLookupService SimpleDatabaseLookupService
AzureStorageCredentialsControllerService_v12 HBase_2_ClientMapCacheService SimpleKeyValueLookupService
AzureStorageCredentialsControllerServiceLookup HBase_2_ClientService SimpleRedisDistributedMapCacheClientService
AzureStorageCredentialsControllerServiceLookup_v12 HBase_2_RecordLookupService SimpleScriptedLookupService
CassandraDistributedMapCache Hive3ConnectionPool SiteToSiteReportingRecordSink
CassandraSessionProvider HiveCatalogService SmbjClientProviderService
CdpCredentialsProviderControllerService HiveConnectionPool SnowflakeComputingConnectionPool
CdpOauth2AccessTokenProviderControllerService HortonworksSchemaRegistry StandardAsanaClientProviderService
CEFReader ImpalaConnectionPool StandardAzureCredentialsControllerService
CiscoEmblemSyslogMessageReader IPFIXReader StandardDropboxCredentialService
ClouderaHiveConnectionPool IPLookupService StandardFileResourceService
ClouderaSchemaRegistry JASN1Reader StandardHashiCorpVaultClientService
CMLLookupService JiraRecordSink StandardHttpContextMap
ConfluentSchemaRegistry JMSConnectionFactoryProvider StandardJsonSchemaRegistry [Technical Preview]
CouchbaseClusterService JndiJmsConnectionFactoryProvider StandardOauth2AccessTokenProvider
CouchbaseKeyValueLookupService JsonConfigBasedBoxClientService StandardPGPPrivateKeyService
CouchbaseMapCacheClient JsonPathReader StandardPGPPublicKeyService
CouchbaseRecordLookupService JsonRecordSetWriter StandardPrivateKeyService
CSVReader JsonTreeReader StandardProxyConfigurationService
CSVRecordLookupService KafkaRecordSink_1_0 StandardRestrictedSSLContextService
CSVRecordSetWriter KafkaRecordSink_2_0 StandardS3EncryptionService
DatabaseRecordLookupService KafkaRecordSink_2_6 StandardSnowflakeIngestManagerProviderService
DatabaseRecordSink KerberosKeytabUserService StandardSSLContextService
DatabaseTableSchemaRegistry KerberosPasswordUserService StandardWebClientServiceProvider
DBCPConnectionPool KerberosTicketCacheUserService Syslog5424Reader
DBCPConnectionPoolLookup KeytabCredentialsService SyslogReader
DistributedMapCacheClientService KuduLookupService UDPEventRecordSink
DistributedMapCacheLookupService LoggingRecordSink VolatileSchemaCache
DistributedMapCacheServer LogHandler WindowsEventLogReader
DistributedSetCacheClientService MongoDBControllerService XMLReader
DistributedSetCacheServer MongoDBLookupService XMLRecordSetWriter
EasyRulesEngineProvider ParquetReader YamlTreeReader
EasyRulesEngineService ParquetRecordSetWriter ZendeskRecordSink
EBCDICRecordReader [Technical Preview] PostgreSQLConnectionPool

NiFi 2.3.0 in Cloudera Flow Management 4.2.1.400

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 KuduLookupService
AzureEventHubRecordSink LoggingRecordSink
AzureServiceBusJMSConnectionFactoryProvider MongoDBControllerService
AzureStorageCredentialsControllerService_v12 MongoDBLookupService
AzureStorageCredentialsControllerServiceLookup_v12 ParquetReader
CassandraDistributedMapCache ParquetRecordSetWriter
CassandraSessionProvider PEMEncodedSSLContextProvider
CdpCredentialsProviderControllerService PhoenixThickConnectionPool
CdpOauth2AccessTokenProviderControllerService PhoenixThinConnectionPool
CEFReader PostgreSQLConnectionPool
CiscoEmblemSyslogMessageReader PrometheusRecordSink
ClouderaAttributeSchemaReferenceReader ProxyPLC4XConnectionPool [Technical Preview]
ClouderaAttributeSchemaReferenceWriter RabbitMQJMSConnectionFactoryProvider
ClouderaEncodedSchemaReferenceReader ReaderLookup
ClouderaEncodedSchemaReferenceWriter RecordSetWriterLookup
ClouderaHiveConnectionPool RecordSinkServiceLookup
ClouderaSchemaRegistry RedisConnectionPoolService
CMLLookupService RedisDistributedMapCacheClientService
ConfluentEncodedSchemaReferenceReader RedshiftConnectionPool
ConfluentEncodedSchemaReferenceWriter RESTCatalogService
ConfluentSchemaRegistry RestLookupService
CouchbaseClusterService ScriptedLookupService
CouchbaseKeyValueLookupService ScriptedReader
CouchbaseMapCacheClient ScriptedRecordSetWriter
CouchbaseRecordLookupService ScriptedRecordSink
CSVReader SimpleDatabaseLookupService
CSVRecordLookupService SimpleKeyValueLookupService
CSVRecordSetWriter SimpleRedisDistributedMapCacheClientService
DatabaseRecordLookupService SimpleScriptedLookupService
DatabaseRecordSink SiteToSiteReportingRecordSink
DatabaseTableSchemaRegistry SlackRecordSink
DeveloperBoxClientService SmbjClientProviderService
DBCPConnectionPool SnowflakeComputingConnectionPool
DBCPConnectionPoolLookup StandardAsanaClientProviderService
DistributedMapCacheClientService StandardAzureCredentialsControllerService
DistributedMapCacheLookupService StandardDatabaseDialectService
DistributedMapCacheServer StandardDropboxCredentialService
DistributedSetCacheClientService StandardFileResourceService
DistributedSetCacheServer StandardHashiCorpVaultClientService
EBCDICRecordReader [Technical Preview] StandardHttpContextMap
ElasticSearchClientServiceImpl StandardJsonSchemaRegistry [Technical Preview]
ElasticSearchLookupService StandardOauth2AccessTokenProvider
ElasticSearchStringLookupService StandardPGPPrivateKeyService
EmailRecordSink StandardPGPPublicKeyService
EmbeddedHazelcastCacheManager StandardPLC4XConnectionPool [Technical Preview]
ExcelReader StandardPrivateKeyService
ExternalHazelcastCacheManager StandardProxyConfigurationService
FreeFormTextRecordSetWriter StandardRestrictedSSLContextService
GCPCredentialsControllerService StandardS3EncryptionService
GCSFileResourceService StandardSnowflakeIngestManagerProviderService
GenericPLC4XConnectionPool [Technical Preview] StandardSSLContextService
GrokReader StandardWebClientServiceProvider
HadoopCatalogService Syslog5424Reader
HadoopDBCPConnectionPool SyslogReader
HazelcastMapCacheClient UDPEventRecordSink
HBase_2_ClientMapCacheService VolatileSchemaCache
HBase_2_ClientService WindowsEventLogReader
HBase_2_RecordLookupService XMLReader
Hive3ConnectionPool XMLRecordSetWriter
HiveCatalogService YamlTreeReader
ImpalaConnectionPool ZendeskRecordSink
IPFIXReader