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