Supported NiFi Processors

This release ships with Apache NiFi 1.15.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 CompressContent12 ConnectWebSocket ConsumeAMQP ConsumeAzureEventHub ConsumeEWS ConsumeGCPubSub ConsumeJMS ConsumeKafka ConsumeKafka_0_10 ConsumeKafka_1_0 ConsumeKafka_2_0 ConsumeKafka_2_6 ConsumeKafka2CDP ConsumeKafka2RecordCDP ConsumeKafkaRecord_0_10 ConsumeKafkaRecord_1_0 ConsumeKafkaRecord_2_0 ConsumeKafkaRecord_2_6 ConsumeKinesisStream ConsumeMQTT 1 ConsumeWindowsEventLog ControlRate ConvertAvroSchema ConvertAvroToJSON ConvertAvroToORC ConvertAvroToParquet ConvertCharacterSet ConvertCSVToAvro ConvertJSONToAvro ConvertJSONToSQL ConvertRecord CreateHadoopSequenceFile CryptographicHashAttribute CryptographicHashContent DecryptContentPGP DeleteAzureBlobStorage DeleteAzureDataLakeStorage DeleteByQueryElasticsearch DeleteCDPObjectStore DeleteDynamoDB DeleteGCSObject DeleteGridFS DeleteHBaseCells DeleteHBaseRow DeleteHDFS DeleteS3Object DeleteSQS DetectDuplicate DistributeLoad DuplicateFlowFile EncryptContent 2 EncryptContentPGP EnforceOrder EvaluateJsonPath EvaluateXPath EvaluateXQuery ExecuteGroovyScript ExecuteInfluxDBQuery ExecuteProcess ExecuteScript ExecuteSQL ExecuteSQLRecord ExecuteStateless ExecuteStreamCommand ExtractAvroMetadata ExtractGrok ExtractHL7Attributes ExtractImageMetadata ExtractText FetchAzureBlobStorage FetchAzureDataLakeStorage FetchCDPObjectStore FetchDistributedMapCache FetchElasticsearch FetchElasticsearchHttp FetchFile FetchFTP FetchGCSObject FetchGridFS FetchHBaseRow FetchHDFS FetchParquet FetchS3Object FetchSFTP FlattenJson ForkRecord GenerateFlowFile GenerateTableFetch GeoEnrichIP GeoEnrichIPRecord GetAzureEventHub GetAzureQueueStorage GetCouchbaseKey 1 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 ListCDPObjectStore ListDatabaseTables ListenFTP ListenGRPC ListenHTTP ListenRELP ListenSyslog ListenTCP ListenTCPRecord ListenUDP ListenUDPRecord ListenWebSocket ListFile ListFTP ListGCSBucket ListHDFS ListS3 ListSFTP LogAttribute LogMessage LookupAttribute LookupRecord MergeContent 1 MergeRecord ModifyHTMLElement MonitorActivity Notify PaginatedJsonQueryElasticsearch ParseCEF ParseEvtx ParseSyslog PartitionRecord PostHTTP PublishAMQP 1 PublishGCPubSub 1 PublishJMS 1 PublishKafka PublishKafka_0_10 PublishKafka_1_0 PublishKafka_2_0 PublishKafka_2_6 PublishKafka2CDP PublishKafka2RecordCDP PublishKafkaRecord_0_10 PublishKafkaRecord_1_0 PublishKafkaRecord_2_0 PublishKafkaRecord_2_6 PublishMQTT 1 PutAccumuloRecord PutAzureBlobStorage PutAzureCosmosDBRecord 1 PutAzureDataLakeStorage PutAzureEventHub 1 PutAzureQueueStorage PutBigQueryBatch PutBigQueryStreaming 1 PutCassandraQL 1 PutCassandraRecord PutCDPObjectStore PutCloudWatchMetric PutCouchbaseKey 1 PutDatabaseRecord PutDistributedMapCache PutDynamoDB 1

PutElasticsearch 1 PutElasticsearchHttp 1 PutElasticsearchHttpRecord PutElasticsearchRecord PutEmail 1 PutFile PutFTP PutGCSObject PutGridFS PutHBaseCell 1 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 1 PutSQL PutSQS PutSyslog PutTCP PutUDP PutWebSocket 1 QueryCassandra QueryDatabaseTable QueryDatabaseTableRecord QueryElasticsearchHttp QueryRecord QuerySolr QuerySplunkIndexingStatus QueryWhois ReplaceText 1 ReplaceTextWithMapping ResizeImage RetryFlowFile RouteHL7 RouteOnAttribute RouteOnContent RouteText SampleRecord 1 ScanAccumulo ScanAttribute ScanContent ScanHBase ScriptedFilterRecord ScriptedPartitionRecord ScriptedTransformRecord ScriptedValidateRecord ScrollElasticsearchHttp SearchElasticsearch SegmentContent SelectHive3QL SelectHiveQL SignContentPGP SplitAvro 1 SplitContent 1 SplitJson 1 SplitRecord SplitText 1 SplitXml 1 TagS3Object TailFile TransformXml UnpackContent UpdateAttribute UpdateByQueryElasticsearch UpdateCounter UpdateHive3Table UpdateHiveTable UpdateRecord ValidateCsv ValidateRecord ValidateXml VerifyContentPGP Wait YandexTranslate

Footnotes

• 1 – indicates a memory intensive processor
• 2 – indicates a CPU intensive processor