Supported NiFi controller services
Learn about the Apache NiFi controller services supported by Cloudera that you can use with Cloudera Data Flow.
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 controller services in your production environments.
2.6.0
| AccumuloService | DistributedSetCacheServer | ProxyPLC4XConnectionPool |
| ActiveMQJMSConnectionFactoryProvider | EBCDICRecordReader | RabbitMQJMSConnectionFactoryProvider |
| ADLSCredentialsControllerService | ElasticSearchClientServiceImpl | ReaderLookup |
| ADLSCredentialsControllerServiceLookup | ElasticSearchLookupService | RecordSetWriterLookup |
| ADLSIDBrokerCloudCredentialsProviderControllerService | ElasticSearchStringLookupService | RecordSinkServiceLookup |
| AmazonGlueSchemaRegistry | EmailRecordSink | RedisConnectionPoolService |
| ApicurioSchemaRegistry | EmbeddedHazelcastCacheManager | RedisDistributedMapCacheClientService |
| AvroReader | ExcelReader | RedshiftConnectionPool |
| AvroRecordSetWriter | ExternalHazelcastCacheManager | RESTCatalogService |
| AvroSchemaRegistry | FreeFormTextRecordSetWriter | RestLookupService |
| AWSCredentialsProviderControllerService | GCPCredentialsControllerService | ScriptedLookupService |
| AWSIDBrokerCloudCredentialsProviderControllerService | GCSFileResourceService | ScriptedReader |
| AzureBlobIDBrokerCloudCredentialsProviderControllerService | GenericPLC4XConnectionPool | ScriptedRecordSetWriter |
| AzureCosmosDBClientService | GrokReader | ScriptedRecordSink |
| AzureEventHubRecordSink | HBase_2_ClientMapCacheService | SimpleDatabaseLookupService |
| AzureServiceBusJMSConnectionFactoryProvider | HBase_2_ClientService | SimpleKeyValueLookupService |
| AzureStorageCredentialsControllerServiceLookup_v12 | HBase_2_RecordLookupService | SimpleRedisDistributedMapCacheClientService |
| AzureStorageCredentialsControllerService_v12 | HadoopCatalogService | SimpleScriptedLookupService |
| CassandraDistributedMapCache | HadoopDBCPConnectionPool | SiteToSiteReportingRecordSink |
| CassandraSessionProvider | HazelcastMapCacheClient | SlackRecordSink |
| CdpCredentialsProviderControllerService | Hive3ConnectionPool | SmbjClientProviderService |
| CdpOauth2AccessTokenProviderControllerService | HiveCatalogService | SnowflakeComputingConnectionPool |
| CEFReader | ImpalaConnectionPool | StandardAsanaClientProviderService |
| CiscoEmblemSyslogMessageReader | IPLookupService | StandardAzureCredentialsControllerService |
| ClouderaAttributeSchemaReferenceReader | IPFIXReader | StandardDatabaseDialectService |
| ClouderaAttributeSchemaReferenceWriter | JASN1Reader | StandardDropboxCredentialService |
| ClouderaEncodedSchemaReferenceReader | JiraRecordSink | StandardFileResourceService |
| ClouderaEncodedSchemaReferenceWriter | JMSConnectionFactoryProvider | StandardHashiCorpVaultClientService |
| ClouderaHiveConnectionPool | JndiJmsConnectionFactoryProvider | StandardHttpContextMap |
| ClouderaHiveConnectionPoolLookup | JsonConfigBasedBoxClientService | StandardJsonSchemaRegistry1 |
| ClouderaSchemaRegistry | JsonPathReader | StandardOauth2AccessTokenProvider |
| CMLLookupService | JsonRecordSetWriter | StandardPLC4XConnectionPool |
| ConfluentEncodedSchemaReferenceReader | JsonTreeReader | StandardPGPPrivateKeyService |
| ConfluentEncodedSchemaReferenceWriter | JWTBearerOAuth2AccessTokenProvider | StandardPGPPublicKeyService |
| ConfluentSchemaRegistry | KafkaRecordSink_2_6 | StandardPrivateKeyService |
| CouchbaseClusterService | KerberosKeytabUserService | StandardProtobufReader |
| CouchbaseKeyValueLookupService | KerberosPasswordUserService | StandardProxyConfigurationService |
| CouchbaseMapCacheClient | KerberosTicketCacheUserService | StandardRestrictedSSLContextService |
| CouchbaseRecordLookupService | KuduLookupService | StandardS3EncryptionService |
| CSVReader | LoggingRecordSink | StandardSnowflakeIngestManagerProviderService |
| CSVRecordLookupService | MongoDBControllerService | StandardSSLContextService |
| CSVRecordSetWriter | MongoDBLookupService | StandardWebClientServiceProvider |
| DatabaseRecordLookupService | MQTTIIoTReader | Syslog5424Reader |
| DatabaseRecordSink | Neo4JCypherClientService | SyslogReader |
| DatabaseTableSchemaRegistry | ParquetReader | TinkerpopClientService |
| DBCPConnectionPool | ParquetRecordSetWriter | UDPEventRecordSink |
| DBCPConnectionPoolLookup | PEMEncodedSSLContextProvider | VolatileSchemaCache |
| DeveloperBoxClientService | PhoenixThickConnectionPool | WindowsEventLogReader |
| DistributedMapCacheClientService | PhoenixThinConnectionPool | XMLReader |
| DistributedMapCacheLookupService | PostgreSQLConnectionPool | XMLRecordSetWriter |
| DistributedMapCacheServer | PrometheusRecordSink | YamlTreeReader |
| DistributedSetCacheClientService | PropertiesFileLookupService | ZendeskRecordSink |
NiFi 1.28.1
| AccumuloService | ElasticSearchStringLookupService | PulsarClientJwtAuthenticationService |
| ActionHandlerLookup | EmailRecordSink | PulsarClientOauthAuthenticationService |
| ActiveMQJMSConnectionFactoryProvider | EmbeddedHazelcastCacheManager | PulsarClientTlsAuthenticationService |
| ADLSCredentialsControllerService | ExcelReader | RabbitMQJMSConnectionFactoryProvider |
| ADLSCredentialsControllerServiceLookup | ExpressionHandler | ReaderLookup |
| ADLSIDBrokerCloudCredentialsProviderControllerService | ExternalHazelcastCacheManager | RecordSetWriterLookup |
| AlertHandler | FreeFormTextRecordSetWriter | RecordSinkHandler |
| AmazonGlueSchemaRegistry | GCPCredentialsControllerService | RecordSinkServiceLookup |
| AvroReader | GrokReader | RedisConnectionPoolService |
| AvroRecordSetWriter | HBase_1_1_2_ClientMapCacheService | RedisDistributedMapCacheClientService |
| AvroSchemaRegistry | HBase_1_1_2_ClientService | RedshiftConnectionPool |
| AWSCredentialsProviderControllerService | HBase_1_1_2_ListLookupService | RestLookupService |
| AWSIDBrokerCloudCredentialsProviderControllerService | HBase_1_1_2_RecordLookupService | ScriptedActionHandler |
| AzureBlobIDBrokerCloudCredentialsProviderControllerService | HBase_2_ClientMapCacheService | ScriptedLookupService |
| AzureCosmosDBClientService | HBase_2_ClientService | ScriptedReader |
| AzureEventHubRecordSink | HBase_2_RecordLookupService | ScriptedRecordSetWriter |
| AzureServiceBusJMSConnectionFactoryProvider | HadoopCatalogService | ScriptedRecordSink |
| AzureStorageCredentialsControllerService | HadoopDBCPConnectionPool | ScriptedRulesEngine |
| AzureStorageCredentialsControllerServiceLookup | HazelcastMapCacheClient | SimpleDatabaseLookupService |
| AzureStorageCredentialsControllerServiceLookup_v12 | Hive3ConnectionPool | SimpleKeyValueLookupService |
| AzureStorageCredentialsControllerService_v12 | HiveCatalogService | SimpleRedisDistributedMapCacheClientService |
| CassandraDistributedMapCache | HiveConnectionPool | SimpleScriptedLookupService |
| CassandraSessionProvider | HortonworksSchemaRegistry | SiteToSiteReportingRecordSink |
| CdpCredentialsProviderControllerService | ImpalaConnectionPool | SmbjClientProviderService |
| CdpOauth2AccessTokenProviderControllerService | IPLookupService | SnowflakeComputingConnectionPool |
| CEFReader | IPFIXReader | StandardAsanaClientProviderService |
| CiscoEmblemSyslogMessageReader | JASN1Reader | StandardAzureCredentialsControllerService |
| ClouderaHiveConnectionPool | JiraRecordSink | StandardDropboxCredentialService |
| ClouderaSchemaRegistry | JMSConnectionFactoryProvider | StandardFileResourceService |
| CMLLookupService | JndiJmsConnectionFactoryProvider | StandardHashiCorpVaultClientService |
| ConfluentSchemaRegistry | JsonConfigBasedBoxClientService | StandardHttpContextMap |
| CouchbaseClusterService | JsonPathReader | StandardJsonSchemaRegistry1 |
| CouchbaseKeyValueLookupService | JsonRecordSetWriter | StandardOauth2AccessTokenProvider |
| CouchbaseMapCacheClient | JsonTreeReader | StandardPGPPrivateKeyService |
| CouchbaseRecordLookupService | KafkaRecordSink_1_0 | StandardPGPPublicKeyService |
| CSVReader | KafkaRecordSink_2_0 | StandardPrivateKeyService |
| CSVRecordLookupService | KafkaRecordSink_2_6 | StandardProxyConfigurationService |
| CSVRecordSetWriter | KerberosKeytabUserService | StandardPulsarClientService |
| DatabaseRecordLookupService | KerberosPasswordUserService | StandardRestrictedSSLContextService |
| DatabaseRecordSink | KerberosTicketCacheUserService | StandardS3EncryptionService |
| DatabaseTableSchemaRegistry | KeytabCredentialsService | StandardSnowflakeIngestManagerProviderService |
| DBCPConnectionPool | KuduLookupService | StandardSSLContextService |
| DBCPConnectionPoolLookup | LogHandler | StandardWebClientServiceProvider |
| DistributedMapCacheClientService | LoggingRecordSink | Syslog5424Reader |
| DistributedMapCacheLookupService | MongoDBControllerService | SyslogReader |
| DistributedMapCacheServer | MongoDBLookupService | UDPEventRecordSink |
| DistributedSetCacheClientService | ParquetReader | VolatileSchemaCache |
| DistributedSetCacheServer | ParquetRecordSetWriter | WindowsEventLogReader |
| EasyRulesEngineProvider | PostgreSQLConnectionPool | XMLReader |
| EasyRulesEngineService | PrometheusRecordSink | XMLRecordSetWriter |
| EBCDICRecordReader1 | ProtobufReader | YamlTreeReader |
| ElasticSearchClientServiceImpl | PulsarClientAthenzAuthenticationService | ZendeskRecordSink |
| ElasticSearchLookupService |
1 Technical preview
2 Apache NiFi
processor
3 Cloudera proprietary processor
4 Memory intensive processor
5 CPU intensive processor
