Supported NiFi processors

Cloudera Flow Management (CFM) is shipped with Apache NiFi and includes a set of processors, most of which are supported by Cloudera. You should be familiar with the available supported processors, and avoid using any unsupported processors in production environments.

Additional processors are developed and tested by the Cloudera community but are not officially supported by Cloudera. Processors 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.

AttributesToCSV GetGcpVisionAnnotateImagesOperationStatus PutElasticsearchHttpRecord1
AttributesToJSON GetHBase PutElasticsearchJson
Base64EncodeContent GetHDFS PutElasticsearchRecord1
CalculateRecordStats GetHDFSFileInfo PutEmail
CaptureChangeMySQL GetHDFSSequenceFile PutFile
CompressContent1,2 GetHTMLElement PutFTP1
ConnectWebSocket GetHTTP PutGCSObject
ConsumeAMQP GetHubSpot PutGoogleDrive
ConsumeAzureEventHub GetIgniteCache PutGridFS
ConsumeEWS GetJiraIssue PutHBaseCell
ConsumeGCPubSub GetJMSQueue PutHBaseJSON
ConsumeGCPubSubLite GetJMSTopic PutHBaseRecord1
ConsumeJMS GetMongoRecord PutHDFS
ConsumeKafka_1_0 GetSFTP PutHive3QL
ConsumeKafka_2_0 GetShopify PutHive3Streaming
ConsumeKafka_2_6 GetSNMP PutHiveQL
ConsumeKafka2CDP GetSnowflakeIngestStatus PutHiveStreaming
ConsumeKafka2RecordCDP GetSolr PutHTMLElement
ConsumeKafkaRecord_1_0 GetSplunk PutIceberg
ConsumeKafkaRecord_2_0 GetSQS PutIcebergCDC [Technical Preview]
ConsumeKafkaRecord_2_6 GetTCP PutInfluxDB
ConsumeKinesisStream GetTwitter PutJMS1
ConsumeMQTT1 GetWorkdayReport PutKinesisFirehose
ConsumeTwitter GetZendesk PutKinesisStream
ConsumeWindowsEventLog HandleHttpRequest PutKudu
ControlRate HandleHttpResponse PutLambda
ConvertAvroSchema HashAttribute PutMongoRecord
ConvertAvroToJSON HashContent PutORC1
ConvertAvroToORC IdentifyMimeType PutParquet
ConvertAvroToParquet InvokeAWSGatewayApi PutRecord
ConvertCharacterSet InvokeGRPC PutRedisHashRecord [Technical Preview]
ConvertCSVToAvro InvokeHTTP PutRiemann
ConvertJSONToAvro InvokeScriptedProcessor PutS3Object
ConvertJSONToSQL JoinEnrichment PutSalesforceObject
ConvertProtobuf JoltTransformJSON PutSFTP
ConvertRecord JoltTransformRecord PutSmbFile
CreateHadoopSequenceFile JSLTTransformJSON PutSnowflakeInternalStage [Technical Preview]
CryptographicHashAttribute JsonQueryElasticsearch PutSNS
CryptographicHashContent ListAzureBlobStorage PutSolrContentStream
DecryptContent ListAzureBlobStorage_v12 PutSolrRecord
DecryptContentCompatibility ListAzureDataLakeStorage PutSplunk
DecryptContentPGP ListBoxFile PutSplunkHTTP
DeduplicateRecord ListCDPObjectStore PutSQL
DeleteAzureBlobStorage ListDatabaseTables PutSQS1
DeleteAzureBlobStorage_v12 ListDropbox PutSyslog
DeleteAzureDataLakeStorage ListenBeats PutTCP
DeleteByQueryElasticsearch ListenFTP PutUDP
DeleteCDPObjectStore ListenGRPC* PutWebSocket1
DeleteDynamoDB ListenGRPC* QueryAirtableTable
DeleteGCSObject ListenHTTP QueryCassandra
DeleteGridFS ListenNetFlow QueryDatabaseTable1
DeleteHBaseCells ListenRELP QueryDatabaseTableRecord
DeleteHBaseRow ListenSyslog QueryElasticsearchHttp
DeleteHDFS ListenTCP QueryRecord
DeleteS3Object ListenTCPRecord QuerySalesforceObject
DeleteSQS ListenTrapSNMP QuerySolr
DetectDuplicate ListenUDP QuerySplunkIndexingStatus
DistributeLoad ListenUDPRecord QueryWhois
DuplicateFlowFile ListenWebSocket RemoveRecordField
EncodeContent ListFile ReplaceText
EncryptContent2 ListFTP ReplaceTextWithMapping
EncryptContentPGP ListGCSBucket ResizeImage1
EnforceOrder ListGoogleDrive RetryFlowFile
EvaluateJsonPath ListHDFS RouteHL7
EvaluateXPath ListS3 RouteOnAttribute
EvaluateXQuery ListSFTP RouteOnContent
ExecuteGroovyScript ListSmb RouteText
ExecuteInfluxDBQuery LogAttribute SampleRecord
ExecuteProcess LogMessage ScanAccumulo
ExecuteScript LookupAttribute ScanAttribute1
ExecuteSQL LookupRecord ScanContent
ExecuteSQLRecord MergeContent ScanHBase
ExecuteStateless1,2 MergeRecord1 ScriptedFilterRecord
ExecuteStreamCommand ModifyCompression ScriptedPartitionRecord
ExtractAvroMetadata ModifyHTMLElement ScriptedTransformRecord
ExtractGrok MonitorActivity ScriptedValidateRecord
ExtractHL7Attributes MoveAzureDataLakeStorage ScrollElasticsearchHttp
ExtractImageMetadata MoveHDFS SearchElasticsearch
ExtractRecordSchema Notify SegmentContent
ExtractText PaginatedJsonQueryElasticsearch SelectHive3QL1
FetchAzureBlobStorage ParseCEF1 SelectHiveQL
FetchAzureBlobStorage_v12 ParseEvtx SendTrapSNMP
FetchAzureDataLakeStorage ParseSyslog SetSNMP
FetchBoxFile PartitionRecord SignContentPGP
FetchCDPObjectStore PostHTTP SplitAvro
FetchDistributedMapCache PublishAMQP SplitContent
FetchDropbox PublishGCPubSub1 SplitJson1
FetchElasticsearchHttp PublishGCPubSubLite1 SplitRecord1
FetchFile PublishJMS1 SplitText1
FetchFTP PublishKafka_1_0 SplitXml
FetchGCSObject PublishKafka_2_0 StartAwsPollyJob
FetchGoogleDrive PublishKafka_2_6 StartAwsTextractJob
FetchGridFS PublishKafka2CDP StartAwsTranscribeJob
FetchHBaseRow PublishKafka2RecordCDP StartAwsTranslateJob
FetchHDFS PublishKafkaRecord_1_0 StartGcpVisionAnnotateFilesOperation
FetchParquet PublishKafkaRecord_2_0 StartGcpVisionAnnotateImagesOperation
FetchS3Object PublishKafkaRecord_2_6 StartSnowflakeIngest [Technical Preview]
FetchSFTP PublishMQTT TagS3Object
FetchSmb PutAccumuloRecord1 TailFile
FlattenJson PutAzureBlobStorage TransformXml
ForkEnrichment PutAzureBlobStorage_v12 TriggerHiveMetaStoreEvent
ForkRecord PutAzureCosmosDBRecord UnpackContent
GenerateFlowFile PutAzureDataLakeStorage1 UpdateAttribute
GenerateRecord PutAzureEventHub UpdateByQueryElasticsearch
GenerateTableFetch PutAzureQueueStorage1 UpdateCounter
GeoEnrichIP PutAzureQueueStorage_v12 UpdateDatabaseTable
GeoEnrichIPRecord PutBigQuery UpdateDeltaLakeTable [Technical Preview]
GeohashRecord PutBigQueryBatch UpdateHive3Table
GetAsanaObject PutBigQueryStreaming UpdateHiveTable
GetAwsPollyJobStatus PutBoxFile UpdateRecord
GetAwsTextractJobStatus PutCassandraQL1 ValidateCsv
GetAwsTranscribeJobStatus PutCassandraRecord1 ValidateJson
GetAwsTranslateJobStatus PutCDPObjectStore ValidateRecord
GetAzureEventHub PutCloudWatchMetric ValidateXml
GetAzureQueueStorage PutCouchbaseKey VerifyContentMAC
GetAzureQueueStorage_v12 PutDatabaseRecord1 VerifyContentPGP
GetCouchbaseKey1 PutDistributedMapCache Wait
GetElasticsearch PutDropbox YandexTranslate
GetFile PutDynamoDB
GetFTP PutDynamoDBRecord
GetGcpVisionAnnotateFilesOperationStatus PutElasticsearchHttp1

Footnotes

  • 1 – indicates a memory intensive processor
  • 2 – indicates a CPU intensive processor
  • * – there are two ListenGRPC processors available, one is provided by Apache and the other is provided by Cloudera