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
| AttributesToCSV | GetElasticsearch | PutDropbox |
| AttributesToJSON | GetFile | PutDynamoDB |
| Base64EncodeContent | GetFTP | PutDynamoDBRecord |
| CalculateParquetOffsets | GetGcpVisionAnnotateFilesOperationStatus | PutElasticsearchHttp |
| CalculateParquetRowGroupOffsets | GetGcpVisionAnnotateImagesOperationStatus | PutElasticsearchHttpRecord |
| CalculateRecordStats | GetHBase | PutElasticsearchJson |
| CaptureChangeDebeziumDB2 [Technical Preview] | GetHDFS | PutElasticsearchRecord |
| CaptureChangeDebeziumMySQL [Technical Preview] | GetHDFSFileInfo | PutEmail |
| CaptureChangeDebeziumOracle [Technical Preview] | GetHDFSSequenceFile | PutFile |
| CaptureChangeDebeziumPostgreSQL [Technical Preview] | GetHTMLElement | PutFTP |
| CaptureChangeDebeziumSQLServer [Technical Preview] | GetHTTP | PutGCSObject |
| CaptureChangeMySQL | GetHubSpot | PutGoogleDrive |
| CompressContent | GetIgniteCache | PutGridFS |
| ConnectWebSocket | GetJiraIssue | PutHBaseCell |
| ConsumeAMQP | GetJMSQueue | PutHBaseJSON |
| ConsumeAzureEventHub | GetJMSTopic | PutHBaseRecord |
| ConsumeElasticsearch | GetMongoRecord | PutHDFS |
| ConsumeEWS | GetSFTP | PutHive3QL |
| ConsumeGCPubSub | GetShopify | PutHive3Streaming |
| ConsumeGCPubSubLite | GetSNMP | PutHiveQL |
| ConsumeJMS | GetSnowflakeIngestStatus | PutHiveStreaming |
| ConsumeKafka_1_0 | GetSolr | PutHTMLElement |
| ConsumeKafka_2_0 | GetSplunk | PutIceberg [Technical Preview] |
| ConsumeKafka_2_6 | GetSQS | PutIcebergCDC |
| ConsumeKafka2CDP | GetTCP | PutInfluxDB |
| ConsumeKafka2RecordCDP | GetTwitter | PutJiraIssue |
| ConsumeKafkaRecord_1_0 | GetWorkdayReport | PutJMS |
| ConsumeKafkaRecord_2_0 | GetZendesk | PutKinesisFirehose |
| ConsumeKafkaRecord_2_6 | HandleHttpRequest | PutKinesisStream |
| ConsumeKinesisStream | HandleHttpResponse | PutKudu |
| ConsumeMQTT | HashAttribute | PutLambda |
| ConsumeTwitter | HashContent | PutMongoRecord |
| ConsumeWindowsEventLog | IdentifyMimeType | PutORC |
| ControlRate | InvokeAWSGatewayApi | PutParquet |
| ConvertAvroSchema | InvokeGRPC | PutRecord |
| ConvertAvroToJSON | InvokeGRPC | PutRedisHashRecord [Technical Preview] |
| ConvertAvroToORC | InvokeHTTP | PutRiemann |
| ConvertAvroToParquet | InvokeScriptedProcessor | PutS3Object |
| ConvertCharacterSet | JoinEnrichment | PutSalesforceObject |
| ConvertCSVToAvro | JoltTransformJSON | PutSFTP |
| ConvertJSONToAvro | JoltTransformRecord | PutSmbFile |
| ConvertJSONToSQL | JSLTTransformJSON | PutSnowflakeInternalStage |
| ConvertProtobuf | JsonQueryElasticsearch | PutSNS |
| ConvertRecord | ListAzureBlobStorage | PutSolrContentStream |
| CountText | ListAzureBlobStorage_v12 | PutSolrRecord |
| CreateHadoopSequenceFile | ListAzureDataLakeStorage | PutSplunk |
| CryptographicHashAttribute | ListBoxFile | PutSplunkHTTP |
| CryptographicHashContent | ListCDPObjectStore | PutSQL |
| DecryptContent | ListDatabaseTables | PutSQS |
| DecryptContentAge | ListDropbox | PutSyslog |
| DecryptContentCompatibility | ListenBeats | PutTCP |
| DecryptContentPGP | ListenFTP | PutUDP |
| DeduplicateRecord | ListenGRPC* | PutWebSocket |
| DeleteAzureBlobStorage | ListenGRPC* | PutZendeskTicket |
| DeleteAzureBlobStorage_v12 | ListenHTTP | QueryAirtableTable |
| DeleteAzureDataLakeStorage | ListenNetFlow | QueryCassandra |
| DeleteByQueryElasticsearch | ListenOTLP | QueryDatabaseTable |
| DeleteCDPObjectStore | ListenRELP | QueryDatabaseTableRecord |
| DeleteDynamoDB | ListenSyslog | QueryElasticsearchHttp |
| DeleteGCSObject | ListenTCP | QueryRecord |
| DeleteGridFS | ListenTCPRecord | QuerySalesforceObject |
| DeleteHBaseCells | ListenTrapSNMP | QuerySolr |
| DeleteHBaseRow | ListenUDP | QuerySplunkIndexingStatus |
| DeleteHDFS | ListenUDPRecord | QueryWhois |
| DeleteS3Object | ListenWebSocket | RemoveRecordField |
| DeleteSQS | ListFile | ReplaceText |
| DetectDuplicate | ListFTP | ReplaceTextWithMapping |
| DistributeLoad | ListGCSBucket | ResizeImage |
| DuplicateFlowFile | ListGoogleDrive | RetryFlowFile |
| EncodeContent | ListHDFS | RouteHL7 |
| EncryptContent | ListS3 | RouteOnAttribute |
| EncryptContentAge | ListSFTP | RouteOnContent |
| EncryptContentPGP | ListSmb | RouteText |
| EnforceOrder | LogAttribute | SampleRecord |
| EvaluateJsonPath | LogMessage | ScanAccumulo |
| EvaluateXPath | LookupAttribute | ScanAttribute |
| EvaluateXQuery | LookupRecord | ScanContent |
| ExecuteGroovyScript | MergeContent | ScanHBase |
| ExecuteInfluxDBQuery | MergeRecord | ScriptedFilterRecord |
| ExecuteProcess | ModifyCompression | ScriptedPartitionRecord |
| ExecuteScript | ModifyHTMLElement | ScriptedTransformRecord |
| ExecuteSQL | MonitorActivity | ScriptedValidateRecord |
| ExecuteSQLRecord | MoveAzureDataLakeStorage | ScrollElasticsearchHttp |
| ExecuteStateless | MoveHDFS | SearchElasticsearch |
| ExecuteStreamCommand | Notify | SegmentContent |
| ExtractAvroMetadata | PackageFlowFile | SelectClouderaHiveQL |
| ExtractGrok | PaginatedJsonQueryElasticsearch | SelectHive3QL |
| ExtractHL7Attributes | ParseCEF | SelectHiveQL |
| ExtractImageMetadata | ParseEvtx | SendTrapSNMP |
| ExtractRecordSchema | ParseSyslog | SetSNMP |
| ExtractText | PartitionRecord | SignContentPGP |
| FetchAzureBlobStorage | PostHTTP | SplitAvro |
| FetchAzureBlobStorage_v12 | PublishAMQP | SplitContent |
| FetchAzureDataLakeStorage | PublishGCPubSub | SplitJson |
| FetchBoxFile | PublishGCPubSubLite | SplitRecord |
| FetchCDPObjectStore | PublishJMS | SplitText |
| FetchDistributedMapCache | PublishKafka_1_0 | SplitXml |
| FetchDropbox | PublishKafka_2_0 | StartAwsPollyJob |
| FetchElasticsearchHttp | PublishKafka_2_6 | StartAwsTextractJob |
| FetchFile | PublishKafka2CDP | StartAwsTranscribeJob |
| FetchFTP | PublishKafka2RecordCDP | StartAwsTranslateJob |
| FetchGCSObject | PublishKafkaRecord_1_0 | StartGcpVisionAnnotateFilesOperation |
| FetchGoogleDrive | PublishKafkaRecord_2_0 | StartGcpVisionAnnotateImagesOperation |
| FetchGridFS | PublishKafkaRecord_2_6 | StartSnowflakeIngest |
| FetchHBaseRow | PublishMQTT | TagS3Object |
| FetchHDFS | PublishSlack | TailFile |
| FetchParquet | PutAccumuloRecord | TransformXml |
| FetchS3Object | PutAzureBlobStorage | TriggerClouderaHiveMetaStoreEvent |
| FetchSFTP | PutAzureBlobStorage_v12 | TriggerHiveMetaStoreEvent |
| FetchSmb | PutAzureCosmosDBRecord | UnpackContent |
| FilterAttribute | PutAzureDataLakeStorage | UpdateAttribute |
| FlattenJson | PutAzureEventHub | UpdateByQueryElasticsearch |
| ForkEnrichment | PutAzureQueueStorage | UpdateClouderaHiveTable |
| ForkRecord | PutAzureQueueStorage_v12 | UpdateCounter |
| GenerateFlowFile | PutBigQuery | UpdateDatabaseTable |
| GenerateRecord | PutBigQueryBatch | UpdateDeltaLakeTable [Technical Preview] |
| GenerateTableFetch | PutBigQueryStreaming | UpdateHive3Table |
| GeoEnrichIP | PutBoxFile | UpdateHiveTable |
| GeoEnrichIPRecord | PutCassandraQL | UpdateRecord |
| GeohashRecord | PutCassandraRecord | ValidateCsv |
| GetAsanaObject | PutCDPObjectStore | ValidateJson |
| GetAwsPollyJobStatus | PutClouderaHiveQL | ValidateRecord |
| GetAwsTextractJobStatus | PutClouderaHiveStreaming | ValidateXml |
| GetAwsTranscribeJobStatus | PutClouderaORC | VerifyContentMAC |
| GetAwsTranslateJobStatus | PutCloudWatchMetric | VerifyContentPGP |
| GetAzureEventHub | PutCouchbaseKey | Wait |
| GetAzureQueueStorage | PutDatabaseRecord | YandexTranslate |
| GetAzureQueueStorage_v12 | PutDistributedMapCache | |
| GetCouchbaseKey |
NiFi 2.4.0
| AttributesToCSV | GetAzureEventHub | PutDynamoDB |
| AttributesToJSON | GetAzureQueueStorage_v12 | PutDynamoDBRecord |
| CalculateParquetOffsets | GetBoxFileCollaborators | PutElasticsearchJson |
| CalculateParquetRowGroupOffsets | GetBoxGroupMembers | PutElasticsearchRecord |
| CalculateRecordStats | GetCouchbaseKey | PutEmail |
| CaptureChangeDebeziumDB2 | GetElasticsearch | PutFile |
| CaptureChangeDebeziumMongoDB | GetFile | PutFTP |
| CaptureChangeDebeziumMySQL | GetFTP | PutGCSObject |
| CaptureChangeDebeziumOracle | GetGcpVisionAnnotateFilesOperationStatus | PutGoogleDrive |
| CaptureChangeDebeziumPostgreSQL | GetGcpVisionAnnotateImagesOperationStatus | PutGridFS |
| CaptureChangeDebeziumSQLServer | GetHBase | PutHBaseCell |
| CaptureChangeMySQL | GetHDFS | PutHBaseJSON |
| ChunkDocument | GetHDFSFileInfo | PutHBaseRecord |
| CompressContent | GetHDFSSequenceFile | PutHDFS |
| ConnectWebSocket | GetHubSpot | PutHive3QL |
| ConsumeAMQP | GetJiraIssue | PutHive3Streaming |
| ConsumeAzureEventHub | GetMongoRecord | PutIceberg |
| ConsumeBoxEnterpriseEvents | GetS3ObjectTags | PutIcebergCDC |
| ConsumeBoxEvents | GetSFTP | PutJiraIssue |
| ConsumeElasticsearch | GetShopify | PutKinesisFirehose |
| ConsumeGCPubSub | GetSNMP | PutKinesisStream |
| ConsumeGCPubSubLite | GetSnowflakeIngestStatus | PutKudu |
| ConsumeJMS | GetSolr | PutLambda |
| ConsumeKafka2CDP | GetSplunk | PutMongoBulkOperations |
| ConsumeKafka2RecordCDP | GetSQS | PutMongoRecord |
| ConsumeKafka_2_6 | GetWorkdayReport | PutORC |
| ConsumeKafkaRecord_2_6 | GetZendesk | PutParquet |
| ConsumeKinesisStream | HandleHttpRequest | PutPinecone |
| ConsumeMQTT | HandleHttpResponse | PutPLC |
| ConsumePLC | IdentifyMimeType | PutRecord |
| ConsumeSlack | InvokeAWSGatewayApi | PutRedisHashRecord* |
| ConsumeTwitter | InvokeGRPC | PutS3Object |
| ConsumeWindowsEventLog | InvokeHTTP | PutSalesforceObject |
| ControlRate | InvokeScriptedProcessor | PutSFTP |
| ConvertAvroToJSON | JoinEnrichment | PutSmbFile |
| ConvertAvroToParquet | JoltTransformJSON | PutSnowflakeInternalStage |
| ConvertCharacterSet | JoltTransformRecord | PutSNS |
| ConvertJSONToSQL | JSLTTransformJSON | PutSolrContentStream |
| ConvertProtobuf | JsonQueryElasticsearch | PutSolrRecord |
| ConvertRecord | ListAzureBlobStorage_v12 | PutSplunk |
| CopyAzureBlobStorage_v12 | ListAzureDataLakeStorage | PutSplunkHTTP |
| CountText | ListBoxFile | PutSQL |
| CreateBoxFileMetadataInstance | ListBoxFileInfo | PutSQS |
| CreateBoxMetadataTemplate | ListBoxFileMetadataInstances | PutSyslog |
| CreateHadoopSequenceFile | ListBoxFileMetadataTemplates | PutTCP |
| CryptographicHashContent | ListCDPObjectStore | PutUDP |
| DecryptContentAge | ListDatabaseTables | PutWebSocket |
| DecryptContentPGP | ListDropbox | PutZendeskTicket |
| DeduplicateRecord | ListenBeats | QueryAirtableTable |
| DeleteAzureBlobStorage_v12 | ListenFTP | QueryCassandra |
| DeleteAzureDataLakeStorage | ListenGRPC | QueryChroma |
| DeleteBoxFileMetadataInstance | ListenHTTP | QueryDatabaseTable |
| DeleteByQueryElasticsearch | ListenNetFlow | QueryDatabaseTableRecord |
| DeleteCDPObjectStore | ListenOTLP | QueryPinecone |
| DeleteDynamoDB | ListenRELP | QueryRecord |
| DeleteGCSObject | ListenSlack | QuerySalesforceObject |
| DeleteGridFS | ListenSyslog | QuerySolr |
| DeleteHBaseCells | ListenTCP | QuerySplunkIndexingStatus |
| DeleteHBaseRow | ListenTCPRecord | QueryWhois |
| DeleteHDFS | ListenTrapSNMP | RemoveRecordField |
| DeleteS3Object | ListenUDP | RenameRecordField |
| DeleteSQS | ListenUDPRecord | ReplaceText |
| DetectDuplicate | ListenWebSocket | ReplaceTextWithMapping |
| DistributeLoad | ListFile | ResizeImage |
| DuplicateFlowFile | ListFTP | RetryFlowFile |
| EncodeContent | ListGCSBucket | RouteHL7 |
| EncryptContentAge | ListGoogleDrive | RouteOnAttribute |
| EncryptContentPGP | ListHDFS | RouteOnContent |
| EnforceOrder | ListS3 | RouteText |
| EvaluateJsonPath | ListSFTP | SampleRecord |
| EvaluateXPath | ListSmb | SawmillTransformJSON |
| EvaluateXQuery | LogAttribute | SawmillTransformRecord |
| ExecuteGraphQuery | LogMessage | ScanAccumulo |
| ExecuteGraphQueryRecord | LookupAttribute | ScanAttribute |
| ExecuteGroovyScript | LookupRecord | ScanContent |
| ExecuteProcess | MergeContent | ScanHBase |
| ExecuteScript | MergeRecord | ScriptedFilterRecord |
| ExecuteSQL | ModifyCompression | ScriptedPartitionRecord |
| ExecuteSQLRecord | MonitorActivity | ScriptedTransformRecord |
| ExecuteStateless | MoveAzureDataLakeStorage | ScriptedValidateRecord |
| ExecuteStreamCommand | MoveHDFS | SearchElasticsearch |
| ExtractAvroMetadata | Notify | SegmentContent |
| ExtractGrok | PackageFlowFile | SelectClouderaHiveQL |
| ExtractHL7Attributes | PaginatedJsonQueryElasticsearch | SelectHive3QL |
| ExtractImageMetadata | ParseCEF | SendTrapSNMP |
| ExtractRecordSchema | ParseDocument | SetSNMP |
| ExtractStructuredBoxFileMetadata | ParseEvtx | SignContentPGP |
| ExtractText | ParseSyslog | SplitAvro |
| FetchAzureBlobStorage_v12 | PartitionRecord | SplitContent |
| FetchAzureDataLakeStorage | PromptAzureOpenAI | SplitJson |
| FetchBoxFile | PromptBedrock | SplitRecord |
| FetchBoxFileInfo | PromptChatGPT | SplitText |
| FetchBoxFileMetadataInstance | PromptClaude | SplitXml |
| FetchBoxFileRepresentation | PromptOpenAI | StartAwsPollyJob |
| FetchCDPObjectStore | PublishAMQP | StartAwsTextractJob |
| FetchDistributedMapCache | PublishGCPubSub | StartAwsTranscribeJob |
| FetchDropbox | PublishGCPubSubLite | StartAwsTranslateJob |
| FetchFile | PublishJMS | StartGcpVisionAnnotateFilesOperation |
| FetchFTP | PublishKafka2CDP | StartGcpVisionAnnotateImagesOperation |
| FetchGCSObject | PublishKafka2RecordCDP | StartSnowflakeIngest |
| FetchGoogleDrive | PublishKafka_2_6 | TagS3Object |
| FetchGridFS | PublishKafkaRecord_2_6 | TailFile |
| FetchHBaseRow | PublishMQTT | TokenCount |
| FetchHDFS | PublishSlack | TransformXml |
| FetchParquet | PutAccumuloRecord | TriggerClouderaHiveMetaStoreEvent |
| FetchPLC | PutAzureBlobStorage_v12 | TriggerHiveMetaStoreEvent |
| FetchS3Object | PutAzureCosmosDBRecord | UnpackContent |
| FetchSFTP | PutAzureDataLakeStorage | UpdateAttribute |
| FetchSmb | PutAzureEventHub | UpdateBoxFileMetadataInstance |
| FilterAttribute | PutAzureQueueStorage_v12 | UpdateByQueryElasticsearch |
| FlattenJson | PutBigQuery | UpdateClouderaHiveTable |
| ForkEnrichment | PutBoxFile | UpdateCounter |
| ForkRecord | PutCassandraQL | UpdateDatabaseTable |
| GenerateFlowFile | PutCassandraRecord | UpdateDeltaLakeTable* |
| GenerateRecord | PutCDPObjectStore | UpdateHive3Table |
| GenerateTableFetch | PutChroma | UpdateRecord |
| GeoEnrichIP | PutClouderaHiveQL | ValidateCsv |
| GeoEnrichIPRecord | PutClouderaHiveStreaming | ValidateJson |
| GeohashRecord | PutClouderaORC | ValidateRecord |
| GetAsanaObject | PutCloudWatchMetric | ValidateXml |
| GetAwsPollyJobStatus | PutCouchbaseKey | VerifyContentMAC |
| GetAwsTextractJobStatus | PutDatabaseRecord | VerifyContentPGP |
| GetAwsTranscribeJobStatus | PutDistributedMapCache | Wait |
| GetAwsTranslateJobStatus | PutDropbox | YandexTranslate |
* - Technical Preview
