Supported 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.

NiFi 1.27

AttributesToJSON Base64EncodeContent CalculateParquetOffsets CalculateParquetRowGroupOffsets CalculateRecordStats CaptureChangeDebeziumDB21 CaptureChangeDebeziumMySQL1 CaptureChangeDebeziumOracle1 CaptureChangeDebeziumPostgreSQL1 CaptureChangeDebeziumSQLServer1 CaptureChangeMySQL CompareFuzzyHash CompressContent ConnectWebSocket ConsumeAMQP ConsumeAzureEventHub ConsumeElasticsearch ConsumeEWS ConsumeGCPubSub ConsumeGCPubSubLite ConsumeIMAP ConsumeJMS ConsumeKafka_2_6 ConsumeKafka2CDP ConsumeKafka2RecordCDP ConsumeKafkaRecord_2_6 ConsumeKinesisStream ConsumeMQTT ConsumePOP3 ConsumeTwitter ConsumeWindowsEventLog ControlRate ConvertAvroToJSON ConvertAvroToParquet ConvertCharacterSet ConvertExcelToCSVProcessor ConvertJSONToSQL ConvertProtobuf ConvertRecord CountText CreateHadoopSequenceFile CryptographicHashAttribute CryptographicHashContent DebugFlow DecryptContent DecryptContentAge DecryptContentCompatibility DecryptContentPGP DeduplicateRecord DeleteAzureBlobStorage DeleteAzureBlobStorage_v12 DeleteAzureDataLakeStorage DeleteByQueryElasticsearch DeleteCDPObjectStore DeleteDynamoDB DeleteGCSObject DeleteGridFS DeleteHBaseCells DeleteHBaseRow DeleteHDFS DeleteMongo DeleteRethinkDB DeleteS3Object DeleteSQS DetectDuplicate DistributeLoad DuplicateFlowFile EncodeContent EncryptContent EncryptContentAge EncryptContentPGP EnforceOrder EvaluateJsonPath EvaluateXPath EvaluateXQuery ExecuteGraphQuery ExecuteGraphQueryRecord ExecuteGroovyScript ExecuteInfluxDBQuery ExecuteProcess ExecuteScript ExecuteSparkInteractive ExecuteSQL ExecuteSQLRecord ExecuteStateless ExecuteStreamCommand ExtractAvroMetadata ExtractCCDAAttributes ExtractDocumentText ExtractEmailAttachments ExtractEmailHeaders ExtractGrok ExtractHL7Attributes ExtractImageMetadata ExtractMediaMetadata ExtractRecordSchema ExtractText ExtractTNEFAttachments FetchAzureBlobStorage FetchAzureBlobStorage_v12 FetchAzureDataLakeStorage FetchBoxFile FetchCDPObjectStore FetchDistributedMapCache FetchDropbox FetchElasticsearchHttp FetchFile FetchFTP FetchGCSObject FetchGoogleDrive FetchGridFS FetchHBaseRow FetchHDFS FetchParquet FetchS3Object FetchSFTP FetchSmb FilterAttribute FlattenJson ForkEnrichment ForkRecord FuzzyHashContent GenerateFlowFile GenerateRecord GenerateTableFetch GeoEnrichIP GeoEnrichIPRecord GeohashRecord GetAsanaObject GetAwsPollyJobStatus GetAwsTextractJobStatus GetAwsTranscribeJobStatus GetAwsTranslateJobStatus GetAzureEventHub GetAzureQueueStorage GetAzureQueueStorage_v12 GetCouchbaseKey GetDynamoDB GetElasticsearch GetFile GetFTP GetGcpVisionAnnotateFilesOperationStatus GetGcpVisionAnnotateImagesOperationStatus GetHBase GetHDFS GetHDFSEvents GetHDFSFileInfo GetHDFSSequenceFile GetHTMLElement GetHTTP GetHubSpot GetJiraIssue GetJMSQueue GetJMSTopic GetMongo GetMongoRecord GetRethinkDB GetSFTP GetShopify GetSmbFile GetSNMP GetSnowflakeIngestStatus GetSolr GetSplunk GetSQS GetTCP GetTwitter GetWorkdayReport GetZendesk HandleHttpRequest HandleHttpResponse HashAttribute HashContent IdentifyMimeType InvokeAWSGatewayApi InvokeGRPC InvokeGRPC InvokeHTTP InvokeScriptedProcessor ISPEnrichIP JoinEnrichment JoltTransformJSON JoltTransformRecord JSLTTransformJSON JsonQueryElasticsearch ListAzureBlobStorage ListAzureBlobStorage_v12 ListAzureDataLakeStorage ListBoxFile ListCDPObjectStore ListDatabaseTables ListDropbox ListenBeats ListenFTP ListenGRPC ListenGRPC ListenHTTP ListenNetFlow ListenOTLP ListenRELP

ListenSMTP ListenSyslog ListenTCP ListenTCPRecord ListenTrapSNMP ListenUDP ListenUDPRecord ListenWebSocket ListFile ListFTP ListGCSBucket ListGoogleDrive ListHDFS ListS3 ListSFTP ListSmb LogAttribute LogMessage LookupAttribute LookupRecord MergeContent MergeRecord ModifyBytes ModifyCompression ModifyHTMLElement MonitorActivity MoveAzureDataLakeStorage MoveHDFS Notify PackageFlowFile PaginatedJsonQueryElasticsearch ParseCEF ParseEvtx ParseNetflowv5 ParseSyslog ParseSyslog5424 PartitionRecord PostHTTP PostSlack PublishAMQP PublishGCPubSub PublishGCPubSubLite PublishJMS PublishKafka_2_6 PublishKafka2CDP PublishKafka2RecordCDP PublishKafkaRecord_2_6 PublishMQTT PublishSlack PutAccumuloRecord PutAzureBlobStorage PutAzureBlobStorage_v12 PutAzureCosmosDBRecord PutAzureDataLakeStorage PutAzureEventHub PutAzureQueueStorage PutAzureQueueStorage_v12 PutBigQuery PutBigQueryBatch PutBigQueryStreaming PutBoxFile PutCassandraQL PutCassandraRecord PutCDPObjectStore PutClouderaHiveQL PutClouderaHiveStreaming PutClouderaORC PutCloudWatchMetric PutCouchbaseKey PutDatabaseRecord PutDistributedMapCache PutDropbox PutDynamoDB PutDynamoDBRecord PutElasticsearchHttp PutElasticsearchHttpRecord PutElasticsearchJson PutElasticsearchRecord PutEmail PutFile PutFTP PutGCSObject PutGoogleDrive PutGridFS PutHBaseCell PutHBaseJSON PutHBaseRecord PutHDFS PutHive3QL PutHive3Streaming PutHTMLElement PutIceberg PutIcebergCDC1 PutInfluxDB PutIoTDBRecord PutJiraIssue PutJMS PutKinesisFirehose PutKinesisStream PutKudu PutLambda PutMongo PutMongoRecord PutORC PutParquet PutRecord PutRethinkDB PutS3Object PutSalesforceObject PutSFTP PutSlack PutSmbFile PutSnowflakeInternalStage PutSNS PutSolrContentStream PutSolrRecord PutSplunk PutSplunkHTTP PutSQL PutSQS PutSyslog PutTCP PutUDP PutWebSocket PutZendeskTicket QueryAirtableTable QueryCassandra QueryDatabaseTable QueryDatabaseTableRecord QueryDNS QueryElasticsearchHttp QueryIoTDBRecord QueryRecord QuerySalesforceObject QuerySolr QuerySplunkIndexingStatus QueryWhois RemoveRecordField ReplaceText ReplaceTextWithMapping ResizeImage RetryFlowFile RouteHL7 RouteOnAttribute RouteOnContent RouteText RunMongoAggregation SampleRecord ScanAccumulo ScanAttribute ScanContent ScanHBase ScriptedFilterRecord ScriptedPartitionRecord ScriptedTransformRecord ScriptedValidateRecord ScrollElasticsearchHttp SearchElasticsearch SegmentContent SelectClouderaHiveQL SelectHive3QL SendTrapSNMP SetSNMP SignContentPGP SplitAvro SplitContent SplitJson SplitRecord SplitText SplitXml SpringContextProcessor StartAwsPollyJob StartAwsTextractJob StartAwsTranscribeJob StartAwsTranslateJob StartGcpVisionAnnotateFilesOperation StartGcpVisionAnnotateImagesOperation StartSnowflakeIngest TagS3Object TailFile TransformXml TriggerClouderaHiveMetaStoreEvent TriggerHiveMetaStoreEvent UnpackContent UpdateAttribute UpdateByQueryElasticsearch UpdateClouderaHiveTable UpdateCounter UpdateDatabaseTable UpdateDeltaLakeTable1 UpdateHive3Table UpdateJiraIssue UpdateRecord ValidateCsv ValidateJson ValidateRecord ValidateXml VerifyContentMAC VerifyContentPGP Wait YandexTranslate

Legend

1 - Technical Preview

NiFi 2.0 [Technical Preview]

AttributeRollingWindow AttributesToCSV AttributesToJSON Bedrock CalculateParquetOffsets CalculateParquetRowGroupOffsets CalculateRecordStats CaptureChangeDebeziumDB2 CaptureChangeDebeziumMySQL CaptureChangeDebeziumOracle CaptureChangeDebeziumPostgreSQL CaptureChangeDebeziumSQLServer CaptureChangeMySQL ChunkData ChunkDocument CompressContent ConnectWebSocket ConsumeAMQP ConsumeAzureEventHub ConsumeElasticsearch ConsumeGCPubSub ConsumeGCPubSubLite ConsumeIMAP ConsumeJMS ConsumeKafka_2_6 ConsumeKafka2CDP ConsumeKafka2RecordCDP ConsumeKafkaRecord_2_6 ConsumeKinesisStream ConsumeMQTT ConsumePOP3 ConsumeSlack ConsumeTwitter ConsumeWindowsEventLog ControlRate ConvertAvroToJSON ConvertAvroToParquet ConvertCharacterSet ConvertJSONToSQL ConvertProtobuf ConvertRecord CopyAzureBlobStorage_v12 CountText CreateHadoopSequenceFile CryptographicHashContent DebugFlow DecryptContent DecryptContentAge DecryptContentCompatibility DecryptContentPGP DeduplicateRecord DeleteAzureBlobStorage_v12 DeleteAzureDataLakeStorage DeleteByQueryElasticsearch DeleteCDPObjectStore DeleteDynamoDB DeleteGCSObject DeleteGridFS DeleteHBaseCells DeleteHBaseRow DeleteHDFS DeleteMongo DeleteS3Object DeleteSQS DetectDuplicate DistributeLoad DuplicateFlowFile EmbedData EncodeContent EncryptContentAge EncryptContentPGP EnforceOrder EvaluateJsonPath EvaluateXPath EvaluateXQuery ExecuteGraphQuery ExecuteGraphQueryRecord ExecuteGroovyScript ExecuteProcess ExecuteScript ExecuteSparkInteractive ExecuteSQL ExecuteSQLRecord ExecuteStateless ExecuteStreamCommand ExtractAvroMetadata ExtractDocumentText ExtractEmailAttachments ExtractEmailHeaders ExtractGrok ExtractHL7Attributes ExtractImageMetadata ExtractMediaMetadata ExtractRecordSchema ExtractText ExtractTNEFAttachments FetchAzureBlobStorage_v12 FetchAzureDataLakeStorage FetchBoxFile FetchCDPObjectStore FetchDistributedMapCache FetchDropbox FetchFile FetchFTP FetchGCSObject FetchGoogleDrive FetchGridFS FetchHBaseRow FetchHDFS FetchParquet FetchS3Object FetchSFTP FetchSmb FilterAttribute FlattenJson ForkEnrichment ForkRecord GenerateFlowFile GenerateRecord GenerateTableFetch GeoEnrichIP GeoEnrichIPRecord GeohashRecord GetAsanaObject GetAwsPollyJobStatus GetAwsTextractJobStatus GetAwsTranscribeJobStatus GetAwsTranslateJobStatus GetAzureEventHub GetAzureQueueStorage_v12 GetCouchbaseKey GetDynamoDB GetElasticsearch GetFile GetFTP GetGcpVisionAnnotateFilesOperationStatus GetGcpVisionAnnotateImagesOperationStatus GetHBase GetHDFS GetHDFSEvents GetHDFSFileInfo GetHDFSSequenceFile GetHubSpot GetJiraIssue GetMongo GetMongoRecord GetSFTP GetShopify GetSmbFile GetSNMP GetSnowflakeIngestStatus GetSolr GetSplunk GetSQS GetWorkdayReport GetZendesk HandleHttpRequest HandleHttpResponse IdentifyMimeType InsertToMilvus InvokeAWSGatewayApi InvokeGRPC InvokeHTTP InvokeScriptedProcessor ISPEnrichIP JoinEnrichment JoltTransformJSON JoltTransformRecord JSLTTransformJSON JsonQueryElasticsearch LexicalQueryMilvus ListAzureBlobStorage_v12 ListAzureDataLakeStorage ListBoxFile ListCDPObjectStore ListDatabaseTables ListDropbox ListenBeats ListenFTP ListenGRPC ListenHTTP ListenNetFlow ListenOTLP ListenRELP ListenSlack ListenSMTP ListenSyslog ListenTCP ListenTCPRecord ListenTrapSNMP ListenUDP ListenUDPRecord ListenWebSocket ListFile ListFTP

ListGCSBucket ListGoogleDrive ListHDFS ListS3 ListSFTP ListSmb LogAttribute LogMessage LookupAttribute LookupRecord MergeContent MergeRecord ModifyBytes ModifyCompression MonitorActivity MoveAzureDataLakeStorage MoveHDFS Notify PackageFlowFile PaginatedJsonQueryElasticsearch ParseCEF ParseDocument ParseEvtx ParseNetflowv5 ParseSyslog ParseSyslog5424 PartitionCsv PartitionDocx PartitionHtml PartitionPdf PartitionRecord PartitionText PromptChatGPT PublishAMQP PublishGCPubSub PublishGCPubSubLite PublishJMS PublishKafka_2_6 PublishKafka2CDP PublishKafka2RecordCDP PublishKafkaRecord_2_6 PublishMQTT PublishSlack PutAccumuloRecord PutAzureBlobStorage_v12 PutAzureCosmosDBRecord PutAzureDataExplorer PutAzureDataLakeStorage PutAzureEventHub PutAzureQueueStorage_v12 PutBigQuery PutBoxFile PutCassandraQL PutCassandraRecord PutCDPObjectStore PutChroma PutClouderaHiveQL PutClouderaHiveStreaming PutClouderaORC PutCloudWatchMetric PutCouchbaseKey PutDatabaseRecord PutDistributedMapCache PutDropbox PutDynamoDB PutDynamoDBRecord PutElasticsearchJson PutElasticsearchRecord PutEmail PutFile PutFTP PutGCSObject PutGoogleDrive PutGridFS PutHBaseCell PutHBaseJSON PutHBaseRecord PutHDFS PutHive3QL PutHive3Streaming PutIceberg PutIcebergCDC PutIoTDBRecord PutJiraIssue PutKinesisFirehose PutKinesisStream PutKudu PutLambda PutMongo PutMongoBulkOperations PutMongoRecord PutOpenSearchVector PutORC PutParquet PutPinecone PutQdrant PutRecord PutRedisHashRecord PutS3Object PutSalesforceObject PutSFTP PutSmbFile PutSnowflakeInternalStage PutSNS PutSolrContentStream PutSolrRecord PutSplunk PutSplunkHTTP PutSQL PutSQS PutSyslog PutTCP PutUDP PutWebSocket PutZendeskTicket QueryAirtableTable QueryAzureDataExplorer QueryCassandra QueryChroma QueryDatabaseTable QueryDatabaseTableRecord QueryDNS QueryIoTDBRecord QueryOpenSearchVector QueryPinecone QueryQdrant QueryRecord QuerySalesforceObject QuerySolr QuerySplunkIndexingStatus QueryWhois RemoveRecordField RenameRecordField ReplaceText ReplaceTextWithMapping ResizeImage RetryFlowFile RouteHL7 RouteOnAttribute RouteOnContent RouteText RunMongoAggregation SampleRecord ScanAccumulo ScanAttribute ScanContent ScanHBase ScriptedFilterRecord ScriptedPartitionRecord ScriptedTransformRecord ScriptedValidateRecord SearchElasticsearch SegmentContent SelectClouderaHiveQL SelectHive3QL SendTrapSNMP SetSNMP SignContentPGP SplitAvro SplitContent SplitJson SplitRecord SplitText SplitXml StartAwsPollyJob StartAwsTextractJob StartAwsTranscribeJob StartAwsTranslateJob StartGcpVisionAnnotateFilesOperation StartGcpVisionAnnotateImagesOperation StartSnowflakeIngest TagS3Object TailFile TransformXml TriggerClouderaHiveMetaStoreEvent TriggerHiveMetaStoreEvent UnpackContent UpdateAttribute UpdateByQueryElasticsearch UpdateClouderaHiveTable UpdateCounter UpdateDatabaseTable UpdateDeltaLakeTable UpdateHive3Table UpdateRecord ValidateCsv ValidateJson ValidateRecord ValidateXml VectorQueryMilvus VerifyContentMAC VerifyContentPGP Wait YandexTranslate