Supported NiFi Processors

Learn about the NiFi Processors supported by Cloudera Support.

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. Do not use these features in your production environments.

Supported processors

  • AttributesToCSV

  • AttributesToJSON

  • Base64EncodeContent

  • CalculateRecordStats

  • CaptureChangeMySQL

  • CompressContent

  • ConnectWebSocket

  • ConsumeAMQP

  • ConsumeAzureEventHub

  • ConsumeEWS

  • ConsumeGCPubSub

  • ConsumeJMS

  • ConsumeKafka

  • ConsumeKafka_0_10

  • ConsumeKafka_1_0

  • ConsumeKafka_2_0

  • ConsumeKafkaRecord_0_10

  • ConsumeKafkaRecord_1_0

  • ConsumeKafkaRecord_2_0

  • ConsumeMQTT

  • ConsumeWindowsEventLog

  • ControlRate

  • ConvertAvroSchema

  • ConvertAvroToJSON

  • ConvertAvroToORC

  • ConvertAvroToParquet

  • ConvertCharacterSet

  • ConvertCSVToAvro

  • ConvertJSONToAvro

  • ConvertJSONToSQL

  • ConvertRecord

  • CreateHadoopSequenceFile

  • CryptographicHashAttribute

  • CryptographicHashContent

  • DeleteAzureBlobStorage

  • DeleteAzureDataLakeStorage

  • DeleteByQueryElasticsearch

  • DeleteDynamoDB

  • DeleteElasticsearch5

  • DeleteGCSObject

  • DeleteGridFS

  • DeleteHBaseCells

  • DeleteHBaseRow

  • DeleteHDFS

  • DeleteS3Object

  • DeleteSQS

  • DetectDuplicate

  • DistributeLoad

  • DuplicateFlowFile

  • EncryptContent

  • EnforceOrder

  • EvaluateJsonPath

  • EvaluateXPath

  • EvaluateXQuery

  • ExecuteGroovyScript

  • ExecuteInfluxDBQuery

  • ExecuteProcess

  • ExecuteScript

  • ExecuteSQL

  • ExecuteSQLRecord

  • ExecuteStreamCommand

  • ExtractAvroMetadata

  • ExtractGrok

  • ExtractHL7Attributes

  • ExtractImageMetadata

  • ExtractText

  • FetchAzureBlobStorage

  • FetchDistributedMapCache

  • FetchElasticsearch

  • FetchElasticsearch5

  • FetchElasticsearchHttp

  • FetchFile

  • FetchFTP

  • FetchGCSObject

  • FetchGridFS

  • FetchHBaseRow

  • FetchHDFS

  • FetchParquet

  • FetchS3Object

  • FetchSFTP

  • FlattenJson

  • ForkRecord

  • GenerateFlowFile

  • GenerateTableFetch

  • GeoEnrichIP

  • GeoEnrichIPRecord

  • GetAzureEventHub

  • GetAzureQueueStorage

  • GetCouchbaseKey

  • 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

  • InvokeHTTP

  • InvokeScriptedProcessor

  • JoltTransformJSON

  • JoltTransformRecord

  • JsonQueryElasticsearch

  • ListAzureBlobStorage

  • ListDatabaseTables

  • ListenHTTP

  • ListenRELP

  • ListenSyslog

  • ListenTCP

  • ListenTCPRecord

  • ListenUDP

  • ListenUDPRecord

  • ListenWebSocket

  • ListFile

  • ListFTP

  • ListGCSBucket

  • ListHDFS

  • ListS3

  • ListSFTP

  • LogAttribute

  • LogMessage

  • LookupAttribute

  • LookupRecord

  • MergeContent

  • MergeRecord

  • ModifyHTMLElement

  • MonitorActivity

  • Notify

  • ParseCEF

  • ParseEvtx

  • ParseSyslog

  • PartitionRecord

  • PostHTTP

  • PublishAMQP

  • PublishGCPubSub

  • PublishJMS

  • PublishKafka

  • PublishKafka_0_10

  • PublishKafka_1_0

  • PublishKafka_2_0

  • PublishKafkaRecord_0_10

  • PublishKafkaRecord_1_0

  • PublishKafkaRecord_2_0

  • PublishMQTT

  • PutAzureBlobStorage

  • PutAzureDataLakeStorage

  • PutAzureEventHub

  • PutAzureQueueStorage

  • PutBigQueryBatch

  • PutBigQueryStreaming

  • PutCassandraQL

  • PutCloudWatchMetric

  • PutCouchbaseKey

  • PutDatabaseRecord

  • PutDistributedMapCache

  • PutDruidRecord

  • PutDynamoDB

  • PutElasticsearch

  • PutElasticsearch5

  • PutElasticsearchHttp

  • PutElasticsearchHttpRecord

  • PutElasticsearchRecord

  • PutEmail

  • PutFile

  • PutFTP

  • PutGCSObject

  • PutGridFS

  • PutHBaseCell

  • PutHBaseJSON

  • PutHBaseRecord

  • PutHDFS

  • PutHive3QL

  • PutHive3Streaming

  • PutHiveQL

  • PutHiveStreaming

  • PutHTMLElement

  • PutInfluxDB

  • PutJMS

  • PutKafka

  • PutKinesisFirehose

  • PutKinesisStream

  • PutKudu

  • PutLambda

  • PutORC

  • PutParquet

  • PutRecord

  • PutRiemann

  • PutS3Object

  • PutSFTP

  • PutSNS

  • PutSolrContentStream

  • PutSolrRecord

  • PutSplunk

  • PutSQL

  • PutSQS

  • PutSyslog

  • PutTCP

  • PutUDP

  • PutWebSocket

  • QueryCassandra

  • QueryDatabaseTable

  • QueryDatabaseTableRecord

  • QueryElasticsearchHttp

  • QueryRecord

  • QuerySolr

  • QueryWhois

  • ReplaceText

  • ReplaceTextWithMapping

  • ResizeImage

  • RetryFlowFile

  • RouteHL7

  • RouteOnAttribute

  • RouteOnContent

  • RouteText

  • ScanAttribute

  • ScanContent

  • ScanHBase

  • ScrollElasticsearchHttp

  • SegmentContent

  • SelectHive3QL

  • SelectHiveQL

  • SplitAvro

  • SplitContent

  • SplitJson

  • SplitRecord

  • SplitText

  • SplitXml

  • TagS3Object

  • TailFile

  • TransformXml

  • UnpackContent

  • UpdateAttribute

  • UpdateCounter

  • UpdateRecord

  • ValidateCsv

  • ValidateRecord

  • ValidateXml

  • Wait

  • YandexTranslate