Supported NiFi controller services

Learn about the Apache NiFi controller services supported by Cloudera that you can use with Cloudera DataFlow.

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 features in your production environments.

NiFi 1.27

AccumuloService ActionHandlerLookup ActiveMQJMSConnectionFactoryProvider ADLSCredentialsControllerService ADLSCredentialsControllerServiceLookup ADLSIDBrokerCloudCredentialsProviderControllerService AlertHandler AmazonGlueSchemaRegistry AvroReader AvroRecordSetWriter AvroSchemaRegistry AWSCredentialsProviderControllerService AWSIDBrokerCloudCredentialsProviderControllerService AzureBlobIDBrokerCloudCredentialsProviderControllerService AzureCosmosDBClientService AzureEventHubRecordSink AzureServiceBusJMSConnectionFactoryProvider AzureStorageCredentialsControllerService AzureStorageCredentialsControllerService_v12 AzureStorageCredentialsControllerServiceLookup AzureStorageCredentialsControllerServiceLookup_v12 AzureStorageEmulatorCredentialsControllerService CassandraDistributedMapCache CassandraSessionProvider CdpCredentialsProviderControllerService CdpOauth2AccessTokenProviderControllerService CEFReader CiscoEmblemSyslogMessageReader ClouderaHiveConnectionPool ClouderaSchemaRegistry CMLLookupService ConfluentSchemaRegistry CouchbaseClusterService CouchbaseKeyValueLookupService CouchbaseMapCacheClient CouchbaseRecordLookupService CSVReader CSVRecordLookupService CSVRecordSetWriter DatabaseRecordLookupService DatabaseRecordSink DatabaseTableSchemaRegistry DBCPConnectionPool DBCPConnectionPoolLookup DistributedMapCacheClientService DistributedMapCacheLookupService DistributedMapCacheServer DistributedSetCacheClientService DistributedSetCacheServer EBCDICRecordReader1 ElasticSearchClientServiceImpl ElasticSearchLookupService ElasticSearchStringLookupService EmailRecordSink EmbeddedHazelcastCacheManager ExcelReader ExpressionHandler ExternalHazelcastCacheManager FreeFormTextRecordSetWriter GCPCredentialsControllerService GraphiteMetricReporterService GremlinClientService GrokReader HadoopCatalogService HadoopDBCPConnectionPool HazelcastMapCacheClient HBase_2_ClientMapCacheService HBase_2_ClientService HBase_2_RecordLookupService HikariCPConnectionPool Hive3ConnectionPool HiveCatalogService HortonworksSchemaRegistry ImpalaConnectionPool IPFIXReader IPLookupService JASN1Reader JettyWebSocketClient JettyWebSocketServer JiraRecordSink

JMSConnectionFactoryProvider JndiJmsConnectionFactoryProvider JsonConfigBasedBoxClientService JsonPathReader JsonRecordSetWriter JsonTreeReader KafkaRecordSink_2_6 KerberosKeytabUserService KerberosPasswordUserService KerberosTicketCacheUserService KeytabCredentialsService KuduLookupService LivySessionController LoggingRecordSink LogHandler MongoDBControllerService MongoDBLookupService Neo4JCypherClientService OAuth2TokenProviderImpl OpenCypherClientService ParquetReader ParquetRecordSetWriter PhoenixThickConnectionPool PhoenixThinConnectionPool PostgreSQLConnectionPool PrometheusRecordSink PropertiesFileLookupService ProtobufReader RabbitMQJMSConnectionFactoryProvider ReaderLookup RecordSetWriterLookup RecordSinkHandler RecordSinkServiceLookup RedisConnectionPoolService RedisDistributedMapCacheClientService RedshiftConnectionPool RestLookupService ScriptedActionHandler ScriptedLookupService ScriptedReader ScriptedRecordSetWriter ScriptedRecordSink ScriptedRulesEngine SimpleCsvFileLookupService SimpleDatabaseLookupService SimpleKeyValueLookupService SimpleRedisDistributedMapCacheClientService SimpleScriptedLookupService SiteToSiteReportingRecordSink SmbjClientProviderService SnowflakeComputingConnectionPool StandardAsanaClientProviderService StandardAzureCredentialsControllerService StandardDropboxCredentialService StandardFileResourceService StandardHashiCorpVaultClientService StandardHttpContextMap StandardJiraCredentialService StandardJsonSchemaRegistry1 StandardOauth2AccessTokenProvider StandardPGPPrivateKeyService StandardPGPPublicKeyService StandardPrivateKeyService StandardProxyConfigurationService StandardRestrictedSSLContextService StandardS3EncryptionService StandardSnowflakeIngestManagerProviderService StandardSSLContextService StandardWebClientServiceProvider Syslog5424Reader SyslogReader UDPEventRecordSink VolatileSchemaCache WindowsEventLogReader XMLFileLookupService XMLReader XMLRecordSetWriter YamlTreeReader ZendeskRecordSink

Legend

1 - Technical Preview

NiFi 2.0 [Technical Preview]

AccumuloService ActiveMQJMSConnectionFactoryProvider ADLSCredentialsControllerService ADLSCredentialsControllerServiceLookup ADLSIDBrokerCloudCredentialsProviderControllerService AmazonGlueSchemaRegistry ApicurioSchemaRegistry AvroReader AvroRecordSetWriter AvroSchemaRegistry AWSCredentialsProviderControllerService AWSIDBrokerCloudCredentialsProviderControllerService AzureBlobIDBrokerCloudCredentialsProviderControllerService AzureCosmosDBClientService AzureEventHubRecordSink AzureServiceBusJMSConnectionFactoryProvider AzureStorageCredentialsControllerService_v12 AzureStorageCredentialsControllerServiceLookup_v12 CassandraDistributedMapCache CassandraSessionProvider CdpCredentialsProviderControllerService CdpOauth2AccessTokenProviderControllerService CEFReader CiscoEmblemSyslogMessageReader ClouderaHiveConnectionPool ClouderaSchemaRegistry CMLLookupService ConfluentEncodedSchemaReferenceReader ConfluentEncodedSchemaReferenceWriter ConfluentSchemaRegistry CouchbaseClusterService CouchbaseKeyValueLookupService CouchbaseMapCacheClient CouchbaseRecordLookupService CSVReader CSVRecordLookupService CSVRecordSetWriter DatabaseRecordLookupService DatabaseRecordSink DatabaseTableSchemaRegistry DBCPConnectionPool DBCPConnectionPoolLookup DistributedMapCacheClientService DistributedMapCacheLookupService DistributedMapCacheServer DistributedSetCacheClientService DistributedSetCacheServer EBCDICRecordReader ElasticSearchClientServiceImpl ElasticSearchLookupService ElasticSearchStringLookupService EmailRecordSink EmbeddedHazelcastCacheManager ExcelReader ExternalHazelcastCacheManager FreeFormTextRecordSetWriter GCPCredentialsControllerService GCSFileResourceService GrokReader HadoopCatalogService HadoopDBCPConnectionPool HazelcastMapCacheClient HBase_2_ClientMapCacheService HBase_2_ClientService HBase_2_RecordLookupService HikariCPConnectionPool Hive3ConnectionPool HiveCatalogService IPFIXReader IPLookupService JASN1Reader JettyWebSocketClient JettyWebSocketServer JiraRecordSink

JMSConnectionFactoryProvider JndiJmsConnectionFactoryProvider JsonConfigBasedBoxClientService JsonPathReader JsonRecordSetWriter JsonTreeReader KafkaRecordSink_2_6 KerberosKeytabUserService KerberosPasswordUserService KerberosTicketCacheUserService KeytabCredentialsService KuduLookupService LivySessionController LoggingRecordSink MongoDBControllerService MongoDBLookupService Neo4JCypherClientService ParquetReader ParquetRecordSetWriter PostgreSQLConnectionPool PrometheusRecordSink PropertiesFileLookupService RabbitMQJMSConnectionFactoryProvider ReaderLookup RecordSetWriterLookup RecordSinkServiceLookup RedisConnectionPoolService RedisDistributedMapCacheClientService RedshiftConnectionPool RestLookupService ScriptedLookupService ScriptedReader ScriptedRecordSetWriter ScriptedRecordSink SimpleCsvFileLookupService SimpleDatabaseLookupService SimpleKeyValueLookupService SimpleRedisDistributedMapCacheClientService SimpleScriptedLookupService SiteToSiteReportingRecordSink SlackRecordSink SmbjClientProviderService SnowflakeComputingConnectionPool StandardAsanaClientProviderService StandardAzureCredentialsControllerService StandardDropboxCredentialService StandardFileResourceService StandardHashiCorpVaultClientService StandardHttpContextMap StandardJsonSchemaRegistry StandardKustoIngestService StandardKustoQueryService StandardOauth2AccessTokenProvider StandardPGPPrivateKeyService StandardPGPPublicKeyService StandardPrivateKeyService StandardProxyConfigurationService StandardRestrictedSSLContextService StandardS3EncryptionService StandardSnowflakeIngestManagerProviderService StandardSSLContextService StandardWebClientServiceProvider Syslog5424Reader SyslogReader TinkerpopClientService UDPEventRecordSink VolatileSchemaCache WindowsEventLogReader XMLFileLookupService XMLReader XMLRecordSetWriter YamlTreeReader ZendeskRecordSink