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.0.
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
| 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.0 in Cloudera Flow Management 4.2.1
| 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 | PostgreSQLConnectionPool |
| CdpCredentialsProviderControllerService | PrometheusRecordSink |
| CdpOauth2AccessTokenProviderControllerService | ProxyPLC4XConnectionPool [Technical Preview] |
| CEFReader | RabbitMQJMSConnectionFactoryProvider |
| CiscoEmblemSyslogMessageReader | ReaderLookup |
| ClouderaHiveConnectionPool | RecordSetWriterLookup |
| ClouderaSchemaRegistry | RecordSinkServiceLookup |
| CMLLookupService | RedisConnectionPoolService |
| ConfluentEncodedSchemaReferenceReader | RedisDistributedMapCacheClientService |
| ConfluentEncodedSchemaReferenceWriter | RedshiftConnectionPool |
| ConfluentSchemaRegistry | RestLookupService |
| CouchbaseClusterService | ScriptedLookupService |
| CouchbaseKeyValueLookupService | ScriptedReader |
| CouchbaseMapCacheClient | ScriptedRecordSetWriter |
| CouchbaseRecordLookupService | ScriptedRecordSink |
| CSVReader | SimpleDatabaseLookupService |
| CSVRecordLookupService | SimpleKeyValueLookupService |
| CSVRecordSetWriter | SimpleRedisDistributedMapCacheClientService |
| DatabaseRecordLookupService | SimpleScriptedLookupService |
| DatabaseRecordSink | SiteToSiteReportingRecordSink |
| DatabaseTableSchemaRegistry | SlackRecordSink |
| DBCPConnectionPool | SmbjClientProviderService |
| DBCPConnectionPoolLookup | SnowflakeComputingConnectionPool |
| DistributedMapCacheClientService | StandardAsanaClientProviderService |
| DistributedMapCacheLookupService | StandardAzureCredentialsControllerService |
| 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 |
