Supported Apache NiFi processors

Learn about the NiFi processors supported by Cloudera that you can 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 CaptureChangeDebeziumDB2* CaptureChangeDebeziumMySQL* CaptureChangeDebeziumOracle* CaptureChangeDebeziumPostgreSQL* CaptureChangeDebeziumSQLServer* CaptureChangeMySQL CompressContent ConnectWebSocket ConsumeAMQP ConsumeAzureEventHub ConsumeElasticsearch ConsumeEWS ConsumeGCPubSub ConsumeGCPubSubLite ConsumeJMS ConsumeKafka_1_0 ConsumeKafka_2_0 ConsumeKafka_2_6 ConsumeKafka2CDP ConsumeKafka2RecordCDP ConsumeKafkaRecord_1_0 ConsumeKafkaRecord_2_0 ConsumeKafkaRecord_2_6 ConsumeKinesisStream ConsumeMQTT ConsumePulsar ConsumePulsarRecord ConsumeTwitter ConsumeWindowsEventLog ControlRate ConvertAvroSchema ConvertAvroToJSON ConvertAvroToORC ConvertAvroToParquet ConvertCharacterSet ConvertCSVToAvro ConvertJSONToAvro ConvertJSONToSQL ConvertProtobuf ConvertRecord CreateHadoopSequenceFile CryptographicHashAttribute CryptographicHashContent DecryptContent DecryptContentAge DecryptContentCompatibility DecryptContentPGP DeduplicateRecord DeleteAzureBlobStorage DeleteAzureBlobStorage_v12 DeleteAzureDataLakeStorage DeleteByQueryElasticsearch DeleteCDPObjectStore DeleteDynamoDB DeleteGCSObject DeleteGridFS DeleteHBaseCells DeleteHBaseRow DeleteHDFS DeleteS3Object DeleteSQS DetectDuplicate DistributeLoad DuplicateFlowFile EncodeContent EncryptContent EncryptContentAge EncryptContentPGP EnforceOrder EvaluateJsonPath EvaluateXPath EvaluateXQuery ExecuteGroovyScript ExecuteInfluxDBQuery ExecuteProcess ExecuteScript ExecuteSQL ExecuteSQLRecord ExecuteStateless ExecuteStreamCommand ExtractAvroMetadata ExtractGrok ExtractHL7Attributes ExtractImageMetadata ExtractRecordSchema ExtractText FetchAzureBlobStorage FetchAzureBlobStorage_v12 FetchAzureDataLakeStorage FetchBoxFile FetchCDPObjectStore FetchDistributedMapCache FetchDropbox FetchElasticsearchHttp FetchFile FetchFTP FetchGCSObject FetchGoogleDrive FetchGridFS FetchHBaseRow FetchHDFS FetchParquet FetchS3Object FetchSFTP FetchSmb FlattenJson ForkEnrichment ForkRecord GenerateFlowFile GenerateRecord GenerateTableFetch GeoEnrichIP GeoEnrichIPRecord GeohashRecord GetAsanaObject GetAwsPollyJobStatus GetAwsTextractJobStatus GetAwsTranscribeJobStatus GetAwsTranslateJobStatus GetAzureEventHub

GetAzureQueueStorage GetAzureQueueStorage_v12 GetCouchbaseKey GetElasticsearch GetFile GetFTP GetGcpVisionAnnotateFilesOperationStatus GetGcpVisionAnnotateImagesOperationStatus GetHBase GetHDFS GetHDFSFileInfo GetHDFSSequenceFile GetHTMLElement GetHTTP GetHubSpot GetIgniteCache GetJiraIssue GetJMSQueue GetJMSTopic GetMongoRecord GetSFTP GetShopify GetSNMP GetSnowflakeIngestStatus GetSolr GetSplunk GetSQS GetTCP GetTwitter GetWorkdayReport GetZendesk HandleHttpRequest HandleHttpResponse HashAttribute HashContent IdentifyMimeType InvokeAWSGatewayApi InvokeGRPC InvokeHTTP InvokeScriptedProcessor JoinEnrichment JoltTransformJSON JoltTransformRecord JSLTTransformJSON JsonQueryElasticsearch ListAzureBlobStorage ListAzureBlobStorage_v12 ListAzureDataLakeStorage ListBoxFile ListCDPObjectStore ListDatabaseTables ListDropbox ListenBeats ListenFTP ListenGRPC ListenGRPC ListenHTTP ListenNetFlow ListenOTLP ListenRELP ListenSyslog ListenTCP ListenTCPRecord ListenTrapSNMP ListenUDP ListenUDPRecord ListenWebSocket ListFile ListFTP ListGCSBucket ListGoogleDrive ListHDFS ListS3 ListSFTP ListSmb LogAttribute LogMessage LookupAttribute LookupRecord MergeContent MergeRecord ModifyCompression ModifyHTMLElement MonitorActivity MoveAzureDataLakeStorage MoveHDFS Notify PaginatedJsonQueryElasticsearch ParseCEF ParseEvtx ParseSyslog PartitionRecord PostHTTP PublishAMQP PublishGCPubSub PublishGCPubSubLite PublishJMS PublishKafka_1_0 PublishKafka_2_0 PublishKafka_2_6 PublishKafka2CDP PublishKafka2RecordCDP PublishKafkaRecord_1_0 PublishKafkaRecord_2_0 PublishKafkaRecord_2_6 PublishMQTT PublishPulsar PublishPulsarRecord PutAccumuloRecord PutAzureBlobStorage PutAzureBlobStorage_v12 PutAzureCosmosDBRecord PutAzureDataLakeStorage PutAzureEventHub PutAzureQueueStorage PutAzureQueueStorage_v12 PutBigQuery PutBigQueryBatch PutBigQueryStreaming PutBoxFile PutCassandraQL PutCassandraRecord PutCDPObjectStore PutCloudWatchMetric

PutCouchbaseKey PutDatabaseRecord PutDistributedMapCache PutDropbox PutDynamoDB PutDynamoDBRecord PutElasticsearchHttp PutElasticsearchHttpRecord PutElasticsearchJson PutElasticsearchRecord PutEmail PutFile PutFTP PutGCSObject PutGoogleDrive PutGridFS PutHBaseCell PutHBaseJSON PutHBaseRecord PutHDFS PutHive3QL PutHive3Streaming PutHiveQL PutHiveStreaming PutHTMLElement PutIceberg PutIcebergCDC* PutInfluxDB PutJMS PutKinesisFirehose PutKinesisStream PutKudu PutLambda PutMongoRecord PutORC PutParquet PutRecord PutS3Object PutSalesforceObject PutSFTP PutSmbFile PutSnowflakeInternalStage* PutSNS PutSolrContentStream PutSolrRecord PutSplunk PutSplunkHTTP PutSQL PutSQS PutSyslog PutTCP PutUDP PutWebSocket QueryAirtableTable QueryCassandra QueryDatabaseTable QueryDatabaseTableRecord QueryElasticsearchHttp QueryRecord QuerySalesforceObject QuerySolr QuerySplunkIndexingStatus QueryWhois RemoveRecordField ReplaceText ReplaceTextWithMapping ResizeImage RetryFlowFile RouteHL7 RouteOnAttribute RouteOnContent RouteText SampleRecord ScanAccumulo ScanAttribute ScanContent ScanHBase ScriptedFilterRecord ScriptedPartitionRecord ScriptedTransformRecord ScriptedValidateRecord ScrollElasticsearchHttp SearchElasticsearch SegmentContent SelectHive3QL SelectHiveQL SendTrapSNMP SetSNMP SignContentPGP SplitAvro SplitContent SplitJson SplitRecord SplitText SplitXml StartAwsPollyJob StartAwsTextractJob StartAwsTranscribeJob StartAwsTranslateJob StartGcpVisionAnnotateFilesOperation StartGcpVisionAnnotateImagesOperation StartSnowflakeIngest* TagS3Object TailFile TransformXml TriggerHiveMetaStoreEvent UnpackContent UpdateAttribute UpdateByQueryElasticsearch UpdateCounter UpdateDatabaseTable UpdateDeltaLakeTable* UpdateHive3Table UpdateHiveTable UpdateRecord ValidateCsv ValidateJson ValidateRecord ValidateXml VerifyContentMAC VerifyContentPGP Wait YandexTranslate

* Technical Preview