Supported NiFi controller services
Learn about the Apache NiFi controller services supported by Cloudera that you can use with Cloudera Flow Management Operator for Kubernetes.
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.
CFM
| AttributesToCSV | GetAzureEventHub | PutDynamoDB |
| AttributesToJSON | GetAzureQueueStorage_v12 | PutDynamoDBRecord |
| CalculateParquetOffsets | GetBoxFileCollaborators | PutElasticsearchJson |
| CalculateParquetRowGroupOffsets | GetBoxGroupMembers | PutElasticsearchRecord4 |
| CalculateRecordStats | GetCouchbaseKey4 | PutEmail |
| CaptureChangeDebeziumDB2 | GetElasticsearch | PutFTP4 |
| CaptureChangeDebeziumMongoDB | GetFTP | PutFile |
| CaptureChangeDebeziumMySQL | GetFile | PutGCSObject |
| CaptureChangeDebeziumOracle | GetGcpVisionAnnotateFilesOperationStatus | PutGoogleDrive |
| CaptureChangeDebeziumPostgreSQL | GetGcpVisionAnnotateImagesOperationStatus | PutGridFS |
| CaptureChangeDebeziumSQLServer | GetHBase | PutHBaseCell |
| CaptureChangeMySQL | GetHDFS | PutHBaseJSON |
| ChunkDocument | GetHDFSFileInfo | PutHBaseRecord4 |
| CompressContent45 | GetHDFSSequenceFile | PutHDFS |
| ConnectWebSocket | GetHubSpot | PutHive3QL |
| ConsumeAMQP | GetJiraIssue | PutHive3Streaming |
| ConsumeAzureEventHub | GetMongoRecord | PutIceberg |
| ConsumeBoxEnterpriseEvents | GetS3ObjectTags | PutIcebergCDC |
| ConsumeBoxEvents | GetSFTP | PutJiraIssue |
| ConsumeElasticsearch | GetSNMP | PutKinesisFirehose |
| ConsumeGCPubSub | GetSQS | PutKinesisStream |
| ConsumeGCPubSubLite | GetShopify | PutKudu |
| ConsumeJMS | GetSnowflakeIngestStatus | PutLambda |
| ConsumeKafka_2_6 | GetSolr | PutMongoBulkOperations |
| ConsumeKafka2CDP | GetSplunk | PutMongoRecord |
| ConsumeKafka2RecordCDP | GetWorkdayReport | PutORC4 |
| ConsumeKafkaRecord_2_6 | GetZendesk | PutPLC |
| ConsumeKinesisStream | HandleHttpRequest | PutParquet |
| ConsumeMQTT4 | HandleHttpResponse | PutPinecone |
| ConsumePLC | IdentifyMimeType | PutRecord |
| ConsumeSlack | InvokeAWSGatewayApi | PutRedisHashRecord1 |
| ConsumeTwitter | InvokeGRPC | PutS3Object |
| ConsumeWindowsEventLog | InvokeHTTP | PutSFTP |
| ControlRate | InvokeScriptedProcessor | PutSNS |
| ConvertAvroToJSON | JoinEnrichment | PutSQL |
| ConvertAvroToParquet | JoltTransformJSON | PutSQS4 |
| ConvertCharacterSet | JoltTransformRecord | PutSalesforceObject |
| ConvertJSONToSQL | JSLTTransformJSON | PutSmbFile |
| ConvertProtobuf | JsonQueryElasticsearch | PutSnowflakeInternalStage |
| ConvertRecord | ListAzureBlobStorage_v12 | PutSolrContentStream |
| CopyAzureBlobStorage_v12 | ListAzureDataLakeStorage | PutSolrRecord |
| CountText | ListBoxFile | PutSplunk |
| CreateBoxFileMetadataInstance | ListBoxFileInfo | PutSplunkHTTP |
| CreateBoxMetadataTemplate | ListBoxFileMetadataInstances | PutSyslog |
| CreateHadoopSequenceFile | ListBoxFileMetadataTemplates | PutTCP |
| CryptographicHashContent | ListCDPObjectStore | PutUDP |
| DecryptContentAge | ListDatabaseTables | PutWebSocket |
| DecryptContentPGP | ListDropbox | PutZendeskTicket |
| DeduplicateRecord | ListFTP | QueryAirtableTable |
| DeleteAzureBlobStorage_v12 | ListFile | QueryCassandra |
| DeleteAzureDataLakeStorage | ListGCSBucket | QueryChroma |
| DeleteBoxFileMetadataInstance | ListGoogleDrive | QueryDatabaseTable4 |
| DeleteByQueryElasticsearch | ListHDFS | QueryDatabaseTableRecord |
| DeleteCDPObjectStore | ListS3 | QueryPinecone |
| DeleteDynamoDB | ListSFTP | QueryRecord |
| DeleteGCSObject | ListSmb | QuerySalesforceObject |
| DeleteGridFS | ListenBeats | QuerySolr |
| DeleteHBaseCells | ListenFTP | QuerySplunkIndexingStatus |
| DeleteHBaseRow | ListenGRPC | QueryWhois |
| DeleteHDFS | ListenHTTP | RemoveRecordField |
| DeleteS3Object | ListenNetFlow | RenameRecordField |
| DeleteSQS | ListenOTLP | ReplaceText |
| DetectDuplicate | ListenRELP | ReplaceTextWithMapping |
| DistributeLoad | ListenSlack | ResizeImage4 |
| DuplicateFlowFile | ListenSyslog | RetryFlowFile |
| EncodeContent | ListenTCP | RouteHL7 |
| EncryptContentAge | ListenTCPRecord | RouteOnAttribute |
| EncryptContentPGP | ListenTrapSNMP | RouteOnContent |
| EnforceOrder | ListenUDP | RouteText |
| EvaluateJsonPath | ListenUDPRecord | SampleRecord |
| EvaluateXPath | ListenWebSocket | SawmillTransformJSON |
| EvaluateXQuery | LogAttribute | SawmillTransformRecord |
| ExecuteGraphQuery | LogMessage | ScanAccumulo |
| ExecuteGraphQueryRecord | LookupAttribute | ScanAttribute4 |
| ExecuteGroovyScript | LookupRecord | ScanContent |
| ExecuteProcess | MergeContent | ScanHBase |
| ExecuteSQL | MergeRecord4 | ScriptedFilterRecord |
| ExecuteScript | ModifyCompression | ScriptedPartitionRecord |
| ExecuteSQLRecord | MonitorActivity | ScriptedTransformRecord |
| ExecuteStateless45 | MoveAzureDataLakeStorage | ScriptedValidateRecord |
| ExecuteStreamCommand | MoveHDFS | SearchElasticsearch |
| ExtractAvroMetadata | Notify | SegmentContent |
| ExtractGrok | PackageFlowFile | SelectClouderaHiveQL |
| ExtractHL7Attributes | PaginatedJsonQueryElasticsearch | SelectHive3QL4 |
| ExtractImageMetadata | ParseCEF4 | SendTrapSNMP |
| ExtractRecordSchema | ParseDocument | SetSNMP |
| ExtractStructuredBoxFileMetadata | ParseEvtx | SignContentPGP |
| ExtractText | ParseSyslog | SplitAvro |
| FetchAzureBlobStorage_v12 | PartitionRecord | SplitContent |
| FetchAzureDataLakeStorage | PromptAzureOpenAI | SplitJson4 |
| FetchBoxFile | PromptBedrock | SplitRecord4 |
| FetchBoxFileInfo | PromptChatGPT | SplitText4 |
| FetchBoxFileMetadataInstance | PromptClaude | SplitXml |
| FetchBoxFileRepresentation | PromptOpenAI | StartAwsPollyJob |
| FetchCDPObjectStore | PublishAMQP | StartAwsTextractJob |
| FetchDistributedMapCache | PublishGCPubSub4 | StartAwsTranscribeJob |
| FetchDropbox | PublishGCPubSubLite4 | StartAwsTranslateJob |
| FetchFTP | PublishJMS4 | StartGcpVisionAnnotateFilesOperation |
| FetchFile | PublishKafka_2_6 | StartGcpVisionAnnotateImagesOperation |
| FetchGCSObject | PublishKafka2CDP | StartSnowflakeIngest |
| FetchGoogleDrive | PublishKafka2RecordCDP | TagS3Object |
| FetchGridFS | PublishKafkaRecord_2_6 | TailFile |
| FetchHBaseRow | PublishMQTT | TokenCount |
| FetchHDFS | PublishSlack | TransformXml |
| FetchPLC | PutAccumuloRecord4 | TriggerClouderaHiveMetaStoreEvent |
| FetchParquet | PutAzureBlobStorage_v12 | TriggerHiveMetaStoreEvent |
| FetchS3Object | PutAzureCosmosDBRecord | UnpackContent |
| FetchSFTP | PutAzureDataLakeStorage4 | UpdateAttribute |
| FetchSmb | PutAzureEventHub | UpdateBoxFileMetadataInstance |
| FilterAttribute | PutAzureQueueStorage_v12 | UpdateByQueryElasticsearch |
| FlattenJson | PutBigQuery | UpdateClouderaHiveTable |
| ForkEnrichment | PutBoxFile | UpdateCounter |
| ForkRecord | PutCassandraQL4 | UpdateDatabaseTable |
| GenerateFlowFile | PutCassandraRecord4 | UpdateDeltaLakeTable1 |
| GenerateRecord | PutCDPObjectStore | UpdateHive3Table |
| GenerateTableFetch | PutChroma | UpdateRecord |
| GeoEnrichIP | PutCloudWatchMetric | ValidateCsv |
| GeoEnrichIPRecord | PutClouderaHiveQL | ValidateJson |
| GeohashRecord | PutClouderaHiveStreaming | ValidateRecord |
| GetAsanaObject | PutClouderaORC | ValidateXml |
| GetAwsPollyJobStatus | PutCouchbaseKey | VerifyContentMAC |
| GetAwsTextractJobStatus | PutDatabaseRecord4 | VerifyContentPGP |
| GetAwsTranscribeJobStatus | PutDistributedMapCache | Wait |
| GetAwsTranslateJobStatus | PutDropbox | YandexTranslate |
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 |
NiFi 2.4
|
|
