Supported NiFi controller services
Cloudera Flow Management is based on Apache NiFi and includes a set of controller services, most of which are supported by Cloudera. 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.
| 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 | MapCacheClientService* |
| AzureStorageCredentialsControllerService_v12 | MapCacheServer** |
| AzureStorageCredentialsControllerServiceLookup_v12 | MongoDBControllerService |
| CassandraDistributedMapCache | MongoDBLookupService |
| CassandraSessionProvider | ParquetReader |
| CdpCredentialsProviderControllerService | ParquetRecordSetWriter |
| CdpOauth2AccessTokenProviderControllerService | PostgreSQLConnectionPool |
| CEFReader | PrometheusRecordSink |
| CiscoEmblemSyslogMessageReader | ProxyPLC4XConnectionPool [Technical Preview] |
| ClouderaHiveConnectionPool | RabbitMQJMSConnectionFactoryProvider |
| ClouderaSchemaRegistry | ReaderLookup |
| CMLLookupService | RecordSetWriterLookup |
| ConfluentEncodedSchemaReferenceReader | RecordSinkServiceLookup |
| ConfluentEncodedSchemaReferenceWriter | RedisConnectionPoolService |
| ConfluentSchemaRegistry | RedisDistributedMapCacheClientService |
| CouchbaseClusterService | RedshiftConnectionPool |
| CouchbaseKeyValueLookupService | RestLookupService |
| CouchbaseMapCacheClient | ScriptedLookupService |
| CouchbaseRecordLookupService | ScriptedReader |
| CSVReader | ScriptedRecordSetWriter |
| CSVRecordLookupService | ScriptedRecordSink |
| CSVRecordSetWriter | SimpleDatabaseLookupService |
| DatabaseRecordLookupService | SimpleKeyValueLookupService |
| DatabaseRecordSink | SimpleRedisDistributedMapCacheClientService |
| DatabaseTableSchemaRegistry | SimpleScriptedLookupService |
| DBCPConnectionPool | SiteToSiteReportingRecordSink |
| DBCPConnectionPoolLookup | SlackRecordSink |
| DistributedMapCacheLookupService | SmbjClientProviderService |
| StandardAzureCredentialsControllerService | SnowflakeComputingConnectionPool |
| DistributedSetCacheClientService | StandardAsanaClientProviderService |
| DistributedSetCacheServer | StandardDropboxCredentialService |
| EBCDICRecordReader [Technical Preview] | StandardFileResourceService |
| ElasticSearchClientServiceImpl | StandardHashiCorpVaultClientService |
| ElasticSearchLookupService | StandardHttpContextMap |
| ElasticSearchStringLookupService | StandardJsonSchemaRegistry [Technical Preview] |
| EmailRecordSink | StandardOauth2AccessTokenProvider |
| EmbeddedHazelcastCacheManager | StandardPGPPrivateKeyService |
| ExcelReader | StandardPGPPublicKeyService |
| ExternalHazelcastCacheManager | StandardPLC4XConnectionPool [Technical Preview] |
| FreeFormTextRecordSetWriter | StandardPrivateKeyService |
| GCPCredentialsControllerService | StandardProxyConfigurationService |
| GCSFileResourceService | StandardRestrictedSSLContextService |
| GenericPLC4XConnectionPool [Technical Preview] | StandardS3EncryptionService |
| GrokReader | StandardSnowflakeIngestManagerProviderService |
| HadoopCatalogService | StandardSSLContextService |
| HadoopDBCPConnectionPool | StandardWebClientServiceProvider |
| HazelcastMapCacheClient | Syslog5424Reader |
| HBase_2_ClientMapCacheService | SyslogReader |
| HBase_2_ClientService | UDPEventRecordSink |
| HBase_2_RecordLookupService | VolatileSchemaCache |
| Hive3ConnectionPool | WindowsEventLogReader |
| HiveCatalogService | XMLReader |
| ImpalaConnectionPool | XMLRecordSetWriter |
| IPFIXReader | YamlTreeReader |
| ZendeskRecordSink |
*The Apache NiFi community has renamed this controller service to better reflect its functionality. This service was not truly “distributed”, so its name has been simplified for clarity. The previous name was DistributedMapCacheClientService.
**The Apache NiFi community has renamed this controller service to better reflect its functionality. This service was not truly “distributed”, so its name has been simplified for clarity. The previous name was DistributedMapCacheServer.
