Supported Apache NiFi Processors

Learn about the NiFi Processors supported by Cloudera Support for use with Cloudera DataFlow.

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.

  • AttributesToCSV
  • AttributesToJSON
  • Base64EncodeContent
  • CalculateRecordStats
  • CaptureChangeMySQL
  • CompressContent
  • 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
  • ControlRate
  • ConvertAvroSchema
  • ConvertAvroToJSON
  • ConvertAvroToORC
  • ConvertAvroToParquet
  • ConvertCharacterSet
  • ConvertCSVToAvro
  • ConvertJSONToAvro
  • ConvertJSONToSQL
  • ConvertRecord
  • CreateHadoopSequenceFile
  • CryptographicHashAttribute
  • CryptographicHashContent
  • DecryptContentPGP
  • DeleteAzureBlobStorage
  • DeleteAzureDataLakeStorage
  • DeleteByQueryElasticsearch
  • DeleteDynamoDB
  • DeleteGCSObject
  • DeleteGridFS
  • DeleteHBaseCells
  • DeleteHBaseRow
  • DeleteHDFS
  • DeleteS3Object
  • DeleteSQS
  • DetectDuplicate
  • DistributeLoad
  • DuplicateFlowFile
  • EncryptContent
  • EncryptContentPGP
  • 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
  • GetFile
  • GetFTP
  • GetHBase
  • GetHDFS
  • GetHDFSFileInfo
  • GetHDFSSequenceFile
  • GetHTMLElement
  • GetHTTP
  • GetIgniteCache
  • GetJMSQueue
  • GetJMSTopic
  • GetKafka
  • GetMongoRecord
  • GetSFTP
  • GetSolr
  • GetSplunk
  • GetSQS
  • GetTCP
  • GetTwitter
  • HashAttribute
  • HashContent
  • IdentifyMimeType
  • InvokeAWSGatewayApi
  • InvokeGRPC
  • InvokeHTTP
  • InvokeScriptedProcessor
  • JoltTransformJSON
  • JoltTransformRecord
  • JsonQueryElasticsearch
  • ListAzureBlobStorage
  • ListAzureDataLakeStorage
  • ListDatabaseTables
  • ListFile
  • ListFTP
  • ListGCSBucket
  • ListHDFS
  • ListS3
  • ListSFTP
  • LogAttribute
  • LogMessage
  • LookupAttribute
  • LookupRecord
  • MergeContent
  • MergeRecord
  • ModifyHTMLElement
  • MonitorActivity
  • Notify
  • ParseCEF
  • ParseEvtx
  • ParseSyslog
  • PartitionRecord
  • PostHTTP
  • PrometheusRecordSink
  • PublishAMQP
  • PublishGCPubSub
  • PublishJMS
  • 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
  • PutAccumuloRecord
  • PutAzureBlobStorage
  • PutAzureCosmosDBRecord
  • PutAzureDataLakeStorage
  • PutAzureEventHub
  • PutAzureQueueStorage
  • PutBigQueryBatch
  • PutBigQueryStreaming
  • PutCassandraQL
  • PutCassandraRecord
  • PutCDPObjectStore
  • PutCloudWatchMetric
  • PutCouchbaseKey
  • PutDatabaseRecord
  • PutDistributedMapCache
  • PutDynamoDB
  • PutElasticsearch
  • PutElasticsearchHttp
  • PutElasticsearchHttpRecord
  • PutElasticsearchRecord
  • PutEmail
  • PutFile
  • PutFTP
  • PutGCSObject
  • PutGridFS
  • PutHBaseCell
  • 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
  • PutSQL
  • PutSQS
  • PutSyslog
  • PutTCP
  • PutUDP
  • PutWebSocket
  • QueryCassandra
  • QueryDatabaseTable
  • QueryDatabaseTableRecord
  • QueryElasticsearchHttp
  • QueryRecord
  • QuerySolr
  • QuerySplunkIndexingStatus
  • QueryWhois
  • ReplaceText
  • ReplaceTextWithMapping
  • ResizeImage
  • RetryFlowFile
  • RouteHL7
  • RouteOnAttribute
  • RouteOnContent
  • RouteText
  • SampleRecord
  • ScanAccumulo
  • ScanAttribute
  • ScanContent
  • ScanHBase
  • ScriptedTransformRecord
  • ScrollElasticsearchHttp
  • SegmentContent
  • SelectHive3QL
  • SelectHiveQL
  • SplitAvro
  • SplitContent
  • SplitJson
  • SplitRecord
  • SplitText
  • SplitXml
  • TagS3Object
  • TailFile
  • TransformXml
  • UnpackContent
  • UpdateAttribute
  • UpdateCounter
  • UpdateHive3Table
  • UpdateHiveTable
  • UpdateRecord
  • ValidateCsv
  • ValidateRecord
  • ValidateXml
  • Wait
  • YandexTranslate