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