Supported NiFi Processors

This release ships with Apache NiFi 1.13.2 and includes a set of Processors, most of which are supported by Cloudera Support. 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 AttributesToJSON Base64EncodeContent CalculateRecordStats CaptureChangeMySQL CompressContent Memory intensive CPU intensive ConnectWebSocket ConsumeAMQP ConsumeAzureEventHub ConsumeEWS ConsumeGCPubSub ConsumeJMS ConsumeKafka ConsumeKafka_0_10 ConsumeKafka_1_0 ConsumeKafka_2_0 ConsumeKafka_2_6 ConsumeKafkaRecord_0_10 ConsumeKafkaRecord_1_0 ConsumeKafkaRecord_2_0 ConsumeKafkaRecord_2_6 ConsumeMQTT Memory intensive ConsumeWindowsEventLog ControlRate ConvertAvroSchema ConvertAvroToJSON ConvertAvroToORC ConvertAvroToParquet ConvertCharacterSet ConvertCSVToAvro ConvertJSONToAvro ConvertJSONToSQL ConvertRecord CreateHadoopSequenceFile CryptographicHashAttribute CryptographicHashContent DeleteAzureBlobStorage DeleteAzureDataLakeStorage DeleteByQueryElasticsearch DeleteDynamoDB DeleteGCSObject DeleteGridFS DeleteHBaseCells DeleteHBaseRow DeleteHDFS DeleteS3Object DeleteSQS DetectDuplicate DistributeLoad DuplicateFlowFile EncryptContent Memory intensive EnforceOrder EvaluateJsonPath EvaluateXPath EvaluateXQuery ExecuteGroovyScript ExecuteInfluxDBQuery ExecuteProcess ExecuteScript ExecuteSQL ExecuteSQLRecord ExecuteStreamCommand ExtractAvroMetadata ExtractGrok ExtractHL7Attributes ExtractImageMetadata ExtractText FetchAzureBlobStorage FetchAzureDataLakeStorage FetchDistributedMapCache FetchElasticsearch FetchElasticsearchHttp FetchFile FetchFTP FetchGCSObject FetchGridFS FetchHBaseRow FetchHDFS FetchParquet FetchS3Object FetchSFTP FlattenJson ForkRecord GenerateFlowFile GenerateTableFetch GeoEnrichIP GeoEnrichIPRecord GetAzureEventHub GetAzureQueueStorage GetCouchbaseKey Memory intensive

GetFile GetFTP GetHBase GetHDFS GetHDFSFileInfo GetHDFSSequenceFile GetHTMLElement GetHTTP GetIgniteCache GetJMSQueue GetJMSTopic GetKafka GetMongoRecord GetSFTP GetSolr GetSplunk GetSQS GetTCP GetTwitter HandleHttpRequest HandleHttpResponse HashAttribute HashContent IdentifyMimeType InvokeAWSGatewayApi InvokeGRPC InvokeHTTP InvokeScriptedProcessor JoltTransformJSON JoltTransformRecord JsonQueryElasticsearch ListAzureBlobStorage ListAzureDataLakeStorage ListDatabaseTables ListenFTP ListenGRPC ListenHTTP ListenRELP ListenSyslog ListenTCP ListenTCPRecord ListenUDP ListenUDPRecord ListenWebSocket ListFile ListFTP ListGCSBucket ListHDFS ListS3 ListSFTP LogAttribute LogMessage LookupAttribute LookupRecord MergeContent Memory intensive MergeRecord ModifyHTMLElement MonitorActivity Notify ParseCEF ParseEvtx ParseSyslog PartitionRecord PostHTTP PublishAMQP Memory intensive PublishGCPubSub Memory intensive PublishJMS Memory intensive PublishKafka PublishKafka_0_10 PublishKafka_1_0 PublishKafka_2_0 PublishKafka_2_6 PublishKafkaRecord_0_10 PublishKafkaRecord_1_0 PublishKafkaRecord_2_0 PublishKafkaRecord_2_6 PublishMQTT Memory intensive PutAccumuloRecord PutAzureBlobStorage PutAzureCosmosDBRecord Memory intensive PutAzureDataLakeStorage PutAzureEventHub Memory intensive PutAzureQueueStorage PutBigQueryBatch PutBigQueryStreaming Memory intensive PutCassandraQL Memory intensive PutCassandraRecord PutCloudWatchMetric PutCouchbaseKey Memory intensive PutDatabaseRecord

PutDistributedMapCache PutDynamoDB Memory intensive PutElasticsearch Memory intensive PutElasticsearchHttp Memory intensive PutElasticsearchHttpRecord PutElasticsearchRecord PutEmail Memory intensive PutFile PutFTP PutGCSObject PutGridFS PutHBaseCell Memory intensive PutHBaseJSON PutHBaseRecord PutHDFS PutHive3QL PutHive3Streaming PutHiveQL PutHiveStreaming PutHTMLElement PutInfluxDB PutJMS PutKafka PutKinesisFirehose PutKinesisStream PutKudu PutLambda PutMongoRecord PutORC PutParquet PutRecord PutRiemann PutS3Object PutSFTP PutSNS PutSolrContentStream PutSolrRecord PutSplunk PutSplunkHTTP Memory intensive PutSQL PutSQS PutSyslog PutTCP PutUDP PutWebSocket Memory intensive QueryCassandra QueryDatabaseTable QueryDatabaseTableRecord QueryElasticsearchHttp QueryRecord QuerySolr QuerySplunkIndexingStatus QueryWhois ReplaceText Memory intensive ReplaceTextWithMapping ResizeImage RetryFlowFile RouteHL7 RouteOnAttribute RouteOnContent RouteText SampleRecord Memory intensive ScanAccumulo ScanAttribute ScanContent ScanHBase ScriptedTransformRecord ScrollElasticsearchHttp SegmentContent SelectHive3QL SelectHiveQL SplitAvro Memory intensive SplitContent Memory intensive SplitJson Memory intensive SplitRecord SplitText Memory intensive SplitXml Memory intensive TagS3Object TailFile TransformXml UnpackContent UpdateAttribute UpdateCounter UpdateHive3Table UpdateHiveTable UpdateRecord ValidateCsv ValidateRecord ValidateXml Wait YandexTranslate