Supported NiFi processors

Learn about the NiFi processors supported by Cloudera that you can use with Cloudera Data Flow.

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 processors in your production environments.

NiFi 1.28.1

AccumuloRecord Aggregation AirtableTable AsanaObject Attribute Attributes AvroMetadata AzureBlobStorage_v12 AzureCosmosDBRecord AzureDataExplorer AzureEventHub AzureQueueStorage_v12 Beats BigQuery BoxEnterpriseEvents BoxFile BoxFileCollaborators BoxFileInfo BoxFileMetadataInstance BoxFileMetadataTemplates BoxFileRepresentation BoxGroupMembers CalculateParquetOffsets CalculateParquetRowGroupOffsets CalculateRecordStats CaptureChangeDebeziumDB2 CaptureChangeDebeziumMongoDB CaptureChangeDebeziumMySQL CaptureChangeDebeziumOracle CaptureChangeDebeziumPostgreSQL CaptureChangeDebeziumSQLServer CaptureChangeMySQL Cassandra CassandraQL CassandraRecord CDPObjectStore ChangeDebeziumDB2 ChangeDebeziumMongoDB ChangeDebeziumMySQL ChangeDebeziumOracle ChangeDebeziumPostgreSQL ChangeDebeziumSQLServer CloudWatchMetric CompressContent Compression ConnectWebSocket ConsumeAMQP ConsumeAzureEventHub ConsumeBoxEvents ConsumeBoxEnterpriseEvents ConsumeElasticsearch ConsumeGCPubSub ConsumeIMAP ConsumeJMS ConsumeKafka ConsumeKafka2CDP ConsumeKafka2RecordCDP ConsumeKafkaRecord_2_6 ConsumeKafka_2_6 ConsumeKinesisStream ConsumeMQTT ConsumePOP3 ConsumePLC ConsumeSlack ConsumeTwitter ConsumeWindowsEventLog Content ControlRate ConvertAvroToParquet ConvertCharacterSet ConvertProtobuf ConvertRecord CopyAzureBlobStorage_v12 CopyS3Object CountText CouchbaseKey CreateBoxFileMetadataInstance CreateBoxMetadataTemplate CreateHadoopSequenceFile CryptographicHashContent DatabaseRecord DatabaseTable DebugFlow DecryptContentAge DecryptContentPGP DeduplicateRecord DeleteAzureBlobStorage_v12 DeleteAzureDataLakeStorage DeleteBoxFileMetadataInstance DeleteByQueryElasticsearch DeleteCDPObjectStore DeleteDynamoDB DeleteFile DeleteGCSObject DeleteGridFS DeleteHBaseCells DeleteHBaseRow DeleteHDFS DeleteMongo DeleteSFTP DeleteS3Object DeleteSQS DeltaLakeTable DetectDuplicate DistributeLoad DocumentText Dropbox DuplicateFlowFile Elasticsearch Email EmailAttachments EmailHeaders EncodeContent EncryptContentAge EncryptContentPGP EnforceOrder EnrichIP EvaluateJsonPath EvaluateXQuery EvaluateXPath Evtx Excel ExecuteGraphQuery ExecuteGraphQueryRecord ExecuteGroovyScript ExecuteProcess ExecuteSQL ExecuteSQLRecord ExecuteScript ExecuteSparkInteractive ExecuteStreamCommand ExtractAvroMetadata ExtractDocumentText ExtractEmailAttachments ExtractEmailHeaders ExtractGrok ExtractHL7Attributes ExtractImageMetadata ExtractMediaMetadata ExtractRecordSchema ExtractStructuredBoxFileMetadata ExtractText FetchAzureBlobStorage_v12 FetchAzureDataLakeStorage FetchBoxFile FetchBoxFileInfo FetchBoxFileMetadataInstance FetchBoxFileRepresentation FetchCDPObjectStore FetchDistributedMapCache FetchDropbox FetchFTP FetchFile FetchGCSObject FetchGridFS FetchHBaseRow FetchHDFS FetchParquet FetchPLC FetchSFTP FetchSmb FilterAttribute FlattenJson FlowFile ForkEnrichment ForkRecord FTP GCSBucket GCSObject GcpVisionAnnotateFilesOperationStatus GcpVisionAnnotateImagesOperationStatus GenerateFlowFile GenerateRecord GenerateTableFetch GeoEnrichIP GeoEnrichIPRecord GetAsanaObject GetAwsPollyJobStatus GetAwsTextractJobStatus GetAwsTranscribeJobStatus GetAwsTranslateJobStatus GetAzureEventHub GetAzureQueueStorage_v12 GetBoxFileCollaborators GetBoxGroupMembers GetCouchbaseKey GetDynamoDB GetElasticsearch GetFTP GetFile GetFileResource GetGcpVisionAnnotateFilesOperationStatus GetGcpVisionAnnotateImagesOperationStatus GetHBase GetHDFSEvents GetHDFSFileInfo GetHDFSSequenceFile GetHubSpot GetJiraIssue GetMongo GetMongoRecord GetSFTP GetSNMP GetSQS GetShopify GetSlackReaction GetSmbFile GetSplunk GetSnowflakeIngestStatus GetTCP GetWorkdayReport GetZendesk GoogleDrive Grok HL7 HandleHttpRequest HandleHttpResponse HBase HBaseCell HBaseJSON HBaseRegions HBaseRow HDFS HDFSEvents HDFSFileInfo HDFSSequenceFile HTTP Iceberg IcebergCDC IdentifyMimeType IoTDBRecord IP ISPEnrichIP InvokeGRPC InvokeHTTP InvokeScriptedProcessor JMS JSLTTransformJSON JiraIssue JoinEnrichment JoltTransformJSON JoltTransformRecord Json JsonQueryElasticsearch Kafka Kafka2CDP Kafka2RecordCDP KafkaRecord_2_6 Kafka_2_6 KinesisFirehose KinesisStream Kudu Lambda ListAzureBlobStorage_v12 ListAzureDataLakeStorage ListBoxFile ListBoxFileInfo ListBoxFileMetadataInstances ListBoxFileMetadataTemplates ListCDPObjectStore ListDatabaseTables ListDropbox ListFTP ListFile ListGCSBucket ListGoogleDrive ListHBaseRegions ListHDFS ListSFTP ListS3 ListSmb ListenBeats ListenFTP ListenGRPC ListenHTTP ListenNetFlow ListenOTLP ListenSlack ListenSyslog ListenTCP ListenTrapSNMP ListenUDP ListenUDPRecord ListenWebSocket LogAttribute LogMessage

LookupAttribute LookupRecord MediaMetadata MergeContent MergeRecord MimeType ModifyBytes ModifyCompression Mongo MongoAggregation MongoBulkOperations MongoRecord MonitorActivity MoveAzureDataLakeStorage MoveHDFS MQTT Netflowv5 Notify ObjectStore PCAP PackageFlowFile PaginatedJsonQueryElasticsearch Parquet ParquetOffsets ParquetRowGroupOffsets ParseEvtx ParseNetflowv5 ParseSyslog ParseSyslog5424 PartitionRecord Pop3 Process PublishAMQP PublishGCPubSub PublishJMS PublishKafka PublishKafka2CDP PublishKafka2RecordCDP PublishKafkaRecord_2_6 PublishKafka_2_6 PublishMQTT PublishSlack PutAccumuloRecord PutAzureBlobStorage_v12 PutAzureCosmosDBRecord PutAzureDataExplorer PutAzureEventHub PutAzureQueueStorage_v12 PutBigQuery PutBoxFile PutCassandraQL PutCassandraRecord PutCDPObjectStore PutClouderaHiveQL PutClouderaHiveStreaming PutClouderaORC PutCloudWatchMetric PutCouchbaseKey PutDatabaseRecord PutDistributedMapCache PutDropbox PutDynamoDB PutDynamoDBRecord PutElasticsearchJson PutElasticsearchRecord PutEmail PutFTP PutFile PutGCSObject PutGoogleDrive PutHBaseCell PutHBaseJSON PutHBaseRecord PutHDFS PutIceberg PutIcebergCDC1 PutIoTDBRecord PutJiraIssue PutKinesisFirehose PutKinesisStream PutKudu PutLambda PutMongo PutMongoBulkOperations PutMongoRecord PutPLC PutParquet PutRedisHashRecord1 PutRecord PutSFTP PutSQL PutSQS PutSalesforceObject PutSmbFile PutSnowflakeInternalStage PutSplunk PutSplunkHTTP PutSyslog PutTCP PutUDP PutWebSocket PutZendeskTicket QueryAirtableTable QueryAzureDataExplorer QueryCassandra QueryDatabaseTable QueryDatabaseTableRecord QueryIoTDBRecord QueryRecord QuerySalesforceObject QuerySolr QuerySplunkIndexingStatus RecordField RecordSchema RecordStats RenameRecordField ReplaceText ReplaceTextWithMapping ResizeImage RetryFlowFile RouteHL7 RouteOnAttribute RouteOnContent RouteText RunMongoAggregation S3Object S3ObjectMetadata S3ObjectTags SalesforceObject SampleRecord SawmillTransformJSON SawmillTransformRecord ScanAccumulo ScanAttribute ScanContent ScanHBase ScriptedFilterRecord ScriptedPartitionRecord ScriptedTransformRecord ScriptedValidateRecord SearchElasticsearch SegmentContent SelectClouderaHiveQL SendTrapSNMP SetSNMP Shopify SignContentPGP Slack SlackReaction Smb SmbFile SnowflakeIngestStatus Solr SolrContentStream SolrRecord SplitAvro SplitContent SplitExcel SplitJson SplitPCAP SplitRecord SplitText SplitXml SQS SQL SQLRecord StartAwsPollyJob StartAwsTextractJob StartAwsTranscribeJob StartAwsTranslateJob StartGcpVisionAnnotateFilesOperation StartGcpVisionAnnotateImagesOperation StartSnowflakeIngest Syslog Syslog5424 TagS3Object TailFile TCP Text TransformXml TriggerClouderaHiveMetaStoreEvent UDP UDPRecord UnpackContent UpdateAttribute UpdateBoxFileMetadataInstance UpdateByQueryElasticsearch UpdateClouderaHiveTable UpdateCounter UpdateDatabaseTable UpdateDeltaLakeTable1 UpdateJiraIssue UpdateRecord ValidateCsv ValidateJson ValidateRecord ValidateXml VerifyContentMAC VerifyContentPGP Wait WebSocket WorkdayReport Zendesk ZendeskTicket

NiFi 2.4.0

AccumuloRecord Aggregation AirtableTable AsanaObject Attribute Attributes AvroMetadata AzureBlobStorage_v12 AzureCosmosDBRecord AzureDataExplorer AzureEventHub AzureQueueStorage_v12 Beats BigQuery BoxEnterpriseEvents BoxFile BoxFileCollaborators BoxFileInfo BoxFileMetadataInstance BoxFileMetadataTemplates BoxFileRepresentation BoxGroupMembers CalculateParquetOffsets CalculateParquetRowGroupOffsets CalculateRecordStats CaptureChangeDebeziumDB21 CaptureChangeDebeziumMongoDB1 CaptureChangeDebeziumMySQL1 CaptureChangeDebeziumOracle1 CaptureChangeDebeziumPostgreSQL1 CaptureChangeDebeziumSQLServer1 CaptureChangeMySQL Cassandra CassandraQL CassandraRecord CDPObjectStore ChangeDebeziumDB2 ChangeDebeziumMongoDB ChangeDebeziumMySQL ChangeDebeziumOracle ChangeDebeziumPostgreSQL ChangeDebeziumSQLServer CloudWatchMetric CompressContent Compression ConnectWebSocket ConsumeAMQP ConsumeAzureEventHub ConsumeBoxEvents ConsumeBoxEnterpriseEvents ConsumeElasticsearch ConsumeGCPubSub ConsumeIMAP ConsumeJMS ConsumeKafka ConsumeKafka2CDP ConsumeKafka2RecordCDP ConsumeKafkaRecord_2_6 ConsumeKafka_2_6 ConsumeKinesisStream ConsumeMQTT ConsumePOP3 ConsumePLC1 ConsumeSlack ConsumeTwitter ConsumeWindowsEventLog Content ControlRate ConvertAvroToParquet ConvertCharacterSet ConvertProtobuf ConvertRecord CopyAzureBlobStorage_v12 CopyS3Object CountText CouchbaseKey CreateBoxFileMetadataInstance CreateBoxMetadataTemplate CreateHadoopSequenceFile CryptographicHashContent DatabaseRecord DatabaseTable DebugFlow DecryptContentAge DecryptContentPGP DeduplicateRecord DeleteAzureBlobStorage_v12 DeleteAzureDataLakeStorage DeleteBoxFileMetadataInstance DeleteByQueryElasticsearch DeleteCDPObjectStore DeleteDynamoDB DeleteFile DeleteGCSObject DeleteGridFS DeleteHBaseCells DeleteHBaseRow DeleteHDFS DeleteMongo DeleteSFTP DeleteS3Object DeleteSQS DeltaLakeTable DetectDuplicate DistributeLoad DocumentText Dropbox DuplicateFlowFile Elasticsearch Email EmailAttachments EmailHeaders EncodeContent EncryptContentAge EncryptContentPGP EnforceOrder EnrichIP EvaluateJsonPath EvaluateXQuery EvaluateXPath Evtx Excel ExecuteGraphQuery ExecuteGraphQueryRecord ExecuteGroovyScript ExecuteProcess ExecuteSQL ExecuteSQLRecord ExecuteScript ExecuteSparkInteractive ExecuteStreamCommand ExtractAvroMetadata ExtractDocumentText ExtractEmailAttachments ExtractEmailHeaders ExtractGrok ExtractHL7Attributes ExtractImageMetadata ExtractMediaMetadata ExtractRecordSchema ExtractStructuredBoxFileMetadata ExtractText FetchAzureBlobStorage_v12 FetchAzureDataLakeStorage FetchBoxFile FetchBoxFileInfo FetchBoxFileMetadataInstance FetchBoxFileRepresentation FetchCDPObjectStore FetchDistributedMapCache FetchDropbox FetchFTP FetchFile FetchGCSObject FetchGridFS FetchHBaseRow FetchHDFS FetchParquet FetchPLC1 FetchSFTP FetchSmb FilterAttribute FlattenJson FlowFile ForkEnrichment ForkRecord FTP GCSBucket GCSObject GcpVisionAnnotateFilesOperationStatus GcpVisionAnnotateImagesOperationStatus GenerateFlowFile GenerateRecord GenerateTableFetch GeoEnrichIP GeoEnrichIPRecord GetAsanaObject GetAwsPollyJobStatus GetAwsTextractJobStatus GetAwsTranscribeJobStatus GetAwsTranslateJobStatus GetAzureEventHub GetAzureQueueStorage_v12 GetBoxFileCollaborators GetBoxGroupMembers GetCouchbaseKey GetDynamoDB GetElasticsearch GetFTP GetFile GetFileResource GetGcpVisionAnnotateFilesOperationStatus GetGcpVisionAnnotateImagesOperationStatus GetHBase GetHDFSEvents GetHDFSFileInfo GetHDFSSequenceFile GetHubSpot GetJiraIssue GetMongo GetMongoRecord GetSFTP GetSNMP GetSQS GetShopify GetSlackReaction GetSmbFile GetSplunk GetSnowflakeIngestStatus GetTCP GetWorkdayReport GetZendesk GoogleDrive Grok HL7 HandleHttpRequest HandleHttpResponse HBase HBaseCell HBaseJSON HBaseRegions HBaseRow HDFS HDFSEvents HDFSFileInfo HDFSSequenceFile HTTP Iceberg IcebergCDC IdentifyMimeType IoTDBRecord IP ISPEnrichIP InvokeGRPC InvokeHTTP InvokeScriptedProcessor JMS JSLTTransformJSON JiraIssue JoinEnrichment JoltTransformJSON JoltTransformRecord Json JsonQueryElasticsearch Kafka Kafka2CDP Kafka2RecordCDP KafkaRecord_2_6 Kafka_2_6 KinesisFirehose KinesisStream Kudu Lambda ListAzureBlobStorage_v12 ListAzureDataLakeStorage ListBoxFile ListBoxFileInfo ListBoxFileMetadataInstances ListBoxFileMetadataTemplates ListCDPObjectStore ListDatabaseTables ListDropbox ListFTP ListFile ListGCSBucket ListGoogleDrive ListHBaseRegions ListHDFS ListSFTP ListS3 ListSmb ListenBeats ListenFTP ListenGRPC ListenHTTP ListenNetFlow ListenOTLP ListenSlack ListenSyslog ListenTCP ListenTrapSNMP ListenUDP ListenUDPRecord ListenWebSocket LogAttribute LogMessage

LookupAttribute LookupRecord MediaMetadata MergeContent MergeRecord MimeType ModifyBytes ModifyCompression Mongo MongoAggregation MongoBulkOperations MongoRecord MonitorActivity MoveAzureDataLakeStorage MoveHDFS MQTT Netflowv5 Notify ObjectStore PCAP PackageFlowFile PaginatedJsonQueryElasticsearch Parquet ParquetOffsets ParquetRowGroupOffsets ParseEvtx ParseNetflowv5 ParseSyslog ParseSyslog5424 PartitionRecord Pop3 Process PublishAMQP PublishGCPubSub PublishJMS PublishKafka PublishKafka2CDP PublishKafka2RecordCDP PublishKafkaRecord_2_6 PublishKafka_2_6 PublishMQTT PublishSlack PutAccumuloRecord PutAzureBlobStorage_v12 PutAzureCosmosDBRecord PutAzureDataExplorer PutAzureEventHub PutAzureQueueStorage_v12 PutBigQuery PutBoxFile PutCassandraQL PutCassandraRecord PutCDPObjectStore PutClouderaHiveQL PutClouderaHiveStreaming PutClouderaORC PutCloudWatchMetric PutCouchbaseKey PutDatabaseRecord PutDistributedMapCache PutDropbox PutDynamoDB PutDynamoDBRecord PutElasticsearchJson PutElasticsearchRecord PutEmail PutFTP PutFile PutGCSObject PutGoogleDrive PutHBaseCell PutHBaseJSON PutHBaseRecord PutHDFS PutIceberg PutIcebergCDC PutIoTDBRecord PutJiraIssue PutKinesisFirehose PutKinesisStream PutKudu PutLambda PutMongo PutMongoBulkOperations PutMongoRecord PutPLC PutParquet PutRedisHashRecord PutRecord PutSFTP PutSQL PutSQS PutSalesforceObject PutSmbFile PutSnowflakeInternalStage PutSplunk PutSplunkHTTP PutSyslog PutTCP PutUDP PutWebSocket PutZendeskTicket QueryAirtableTable QueryAzureDataExplorer QueryCassandra QueryDatabaseTable QueryDatabaseTableRecord QueryIoTDBRecord QueryRecord QuerySalesforceObject QuerySolr QuerySplunkIndexingStatus RecordField RecordSchema RecordStats RenameRecordField ReplaceText ReplaceTextWithMapping ResizeImage RetryFlowFile RouteHL7 RouteOnAttribute RouteOnContent RouteText RunMongoAggregation S3Object S3ObjectMetadata S3ObjectTags SalesforceObject SampleRecord SawmillTransformJSON SawmillTransformRecord ScanAccumulo ScanAttribute ScanContent ScanHBase ScriptedFilterRecord ScriptedPartitionRecord ScriptedTransformRecord ScriptedValidateRecord SearchElasticsearch SegmentContent SelectClouderaHiveQL SendTrapSNMP SetSNMP Shopify SignContentPGP Slack SlackReaction Smb SmbFile SnowflakeIngestStatus Solr SolrContentStream SolrRecord SplitAvro SplitContent SplitExcel SplitJson SplitPCAP SplitRecord SplitText SplitXml SQS SQL SQLRecord StartAwsPollyJob StartAwsTextractJob StartAwsTranscribeJob StartAwsTranslateJob StartGcpVisionAnnotateFilesOperation StartGcpVisionAnnotateImagesOperation StartSnowflakeIngest Syslog Syslog5424 TagS3Object TailFile TCP Text TransformXml TriggerClouderaHiveMetaStoreEvent UDP UDPRecord UnpackContent UpdateAttribute UpdateBoxFileMetadataInstance UpdateByQueryElasticsearch UpdateClouderaHiveTable UpdateCounter UpdateDatabaseTable UpdateDeltaLakeTable1 UpdateJiraIssue UpdateRecord ValidateCsv ValidateJson ValidateRecord ValidateXml VerifyContentMAC VerifyContentPGP Wait WebSocket WorkdayReport Zendesk ZendeskTicket

Python processors [Technical Preview]

ChunkData ChunkDocument EmbedData InsertToMilvus LexicalQueryMilvus ParseDocument PartitionCsv PartitionDocx PartitionHtml PartitionPdf PartitionText

PromptAzureOpenAI PromptBedrock PromptChatGPT PromptClaude PromptOpenAI PutChroma PutOpenSearchVector PutPinecone PutQdrant QueryChroma QueryOpenSearchVector QueryPinecone QueryQdrant TokenCount VectorQueryMilvus