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 |
