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 | 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 |
NiFi 2.4.0
| AttributesToCSV | GetAzureEventHub | PutDynamoDB |
| AttributesToJSON | GetAzureQueueStorage_v12 | PutDynamoDBRecord |
| CalculateParquetOffsets | GetBoxFileCollaborators | PutElasticsearchJson |
| CalculateParquetRowGroupOffsets | GetBoxGroupMembers | PutElasticsearchRecord |
| CalculateRecordStats | GetCouchbaseKey | PutEmail |
| CaptureChangeDebeziumDB2 | GetElasticsearch | PutFTP |
| CaptureChangeDebeziumMongoDB | GetFTP | PutFile |
| CaptureChangeDebeziumMySQL | GetFile | 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 | GetSNMP | PutKinesisFirehose |
| ConsumeGCPubSub | GetSQS | PutKinesisStream |
| ConsumeGCPubSubLite | GetShopify | PutKudu |
| ConsumeJMS | GetSnowflakeIngestStatus | PutLambda |
| ConsumeKafka_2_6 | GetSolr | PutMongoBulkOperations |
| ConsumeKafka2CDP | GetSplunk | PutMongoRecord |
| ConsumeKafka2RecordCDP | GetWorkdayReport | PutORC |
| ConsumeKafkaRecord_2_6 | GetZendesk | PutPLC |
| ConsumeKinesisStream | HandleHttpRequest | PutParquet |
| ConsumeMQTT | HandleHttpResponse | PutPinecone |
| ConsumePLC | IdentifyMimeType | PutRecord |
| ConsumeSlack | InvokeAWSGatewayApi | PutRedisHashRecord1 |
| ConsumeTwitter | InvokeGRPC | PutS3Object |
| ConsumeWindowsEventLog | InvokeHTTP | PutSFTP |
| ControlRate | InvokeScriptedProcessor | PutSNS |
| ConvertAvroToJSON | JoinEnrichment | PutSQL |
| ConvertAvroToParquet | JoltTransformJSON | PutSQS |
| ConvertCharacterSet | JoltTransformRecord | PutSalesforceObject |
| ConvertJSONToSQL | JSLTTransformJSON | PutSmbFile |
| ConvertProtobuf | JsonQueryElasticsearch | PutSnowflakeInternalStage |
| ConvertRecord | ListAzureBlobStorage_v12 | PutSolrContentStream |
| CopyAzureBlobStorage_v12 | ListAzureDataLakeStorage | PutSolrRecord |
| CountText | ListBoxFile | PutSplunk |
| CreateBoxFileMetadataInstance | ListBoxFileInfo | PutSplunkHTTP |
| CreateBoxMetadataTemplate | ListBoxFileMetadataInstances | PutSyslog |
| CreateHadoopSequenceFile | ListBoxFileMetadataTemplates | PutTCP |
| CryptographicHashContent | ListCDPObjectStore | PutUDP |
| DecryptContentAge | ListDatabaseTables | PutWebSocket |
| DecryptContentPGP | ListDropbox | PutZendeskTicket |
| DeduplicateRecord | ListFTP | QueryAirtableTable |
| DeleteAzureBlobStorage_v12 | ListFile | QueryCassandra |
| DeleteAzureDataLakeStorage | ListGCSBucket | QueryChroma |
| DeleteBoxFileMetadataInstance | ListGoogleDrive | QueryDatabaseTable |
| DeleteByQueryElasticsearch | ListHDFS | QueryDatabaseTableRecord |
| DeleteCDPObjectStore | ListS3 | QueryPinecone |
| DeleteDynamoDB | ListSFTP | QueryRecord |
| DeleteGCSObject | ListSmb | QuerySalesforceObject |
| DeleteGridFS | ListenBeats | QuerySolr |
| DeleteHBaseCells | ListenFTP | QuerySplunkIndexingStatus |
| DeleteHBaseRow | ListenGRPC | QueryWhois |
| DeleteHDFS | ListenHTTP | RemoveRecordField |
| DeleteS3Object | ListenNetFlow | RenameRecordField |
| DeleteSQS | ListenOTLP | ReplaceText |
| DetectDuplicate | ListenRELP | ReplaceTextWithMapping |
| DistributeLoad | ListenSlack | ResizeImage |
| DuplicateFlowFile | ListenSyslog | RetryFlowFile |
| EncodeContent | ListenTCP | RouteHL7 |
| EncryptContentAge | ListenTCPRecord | RouteOnAttribute |
| EncryptContentPGP | ListenTrapSNMP | RouteOnContent |
| EnforceOrder | ListenUDP | RouteText |
| EvaluateJsonPath | ListenUDPRecord | SampleRecord |
| EvaluateXPath | ListenWebSocket | SawmillTransformJSON |
| EvaluateXQuery | LogAttribute | SawmillTransformRecord |
| ExecuteGraphQuery | LogMessage | ScanAccumulo |
| ExecuteGraphQueryRecord | LookupAttribute | ScanAttribute |
| ExecuteGroovyScript | LookupRecord | ScanContent |
| ExecuteProcess | MergeContent | ScanHBase |
| ExecuteSQL | MergeRecord | ScriptedFilterRecord |
| ExecuteScript | 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 |
| FetchFTP | PublishJMS | StartGcpVisionAnnotateFilesOperation |
| FetchFile | PublishKafka_2_6 | StartGcpVisionAnnotateImagesOperation |
| FetchGCSObject | PublishKafka2CDP | StartSnowflakeIngest |
| FetchGoogleDrive | PublishKafka2RecordCDP | TagS3Object |
| FetchGridFS | PublishKafkaRecord_2_6 | TailFile |
| FetchHBaseRow | PublishMQTT | TokenCount |
| FetchHDFS | PublishSlack | TransformXml |
| FetchPLC | PutAccumuloRecord | TriggerClouderaHiveMetaStoreEvent |
| FetchParquet | 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 | UpdateDeltaLakeTable1 |
| GenerateRecord | PutCDPObjectStore | UpdateHive3Table |
| GenerateTableFetch | PutChroma | UpdateRecord |
| GeoEnrichIP | PutCloudWatchMetric | ValidateCsv |
| GeoEnrichIPRecord | PutClouderaHiveQL | ValidateJson |
| GeohashRecord | PutClouderaHiveStreaming | ValidateRecord |
| GetAsanaObject | PutClouderaORC | ValidateXml |
| GetAwsPollyJobStatus | PutCouchbaseKey | VerifyContentMAC |
| GetAwsTextractJobStatus | PutDatabaseRecord | VerifyContentPGP |
| GetAwsTranscribeJobStatus | PutDistributedMapCache | Wait |
| GetAwsTranslateJobStatus | PutDropbox | YandexTranslate |
