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

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 PutGridFS
ConnectWebSocket GetJiraIssue PutHBaseCell
ConsumeAMQP GetJMSQueue PutHBaseJSON
ConsumeAzureEventHub GetJMSTopic PutHBaseRecord
ConsumeElasticsearch GetMongoRecord PutHDFS
ConsumeEWS GetSFTP PutHive3QL
ConsumeGCPubSub GetShopify PutHive3Streaming
ConsumeGCPubSubLite GetSNMP
ConsumeJMS GetSnowflakeIngestStatus
GetSolr PutHTMLElement
GetSplunk PutIceberg
ConsumeKafka_2_6 GetSQS PutIcebergCDC [Technical Preview]
ConsumeKafka2CDP GetTCP PutInfluxDB
ConsumeKafka2RecordCDP GetTwitter PutJiraIssue
GetWorkdayReport PutJMS
GetZendesk PutKinesisFirehose
ConsumeKafkaRecord_2_6 HandleHttpRequest PutKinesisStream
ConsumeKinesisStream HandleHttpResponse PutKudu
ConsumeMQTT HashAttribute PutLambda
ConsumeTwitter HashContent PutMongoRecord
ConsumeWindowsEventLog IdentifyMimeType PutORC
ControlRate InvokeAWSGatewayApi PutParquet
InvokeGRPC PutRecord
ConvertAvroToJSON InvokeGRPC PutRedisHashRecord [Technical Preview]
InvokeHTTP PutRiemann
ConvertAvroToParquet InvokeScriptedProcessor PutS3Object
ConvertCharacterSet JoinEnrichment PutSalesforceObject
JoltTransformJSON PutSFTP
JoltTransformRecord PutSmbFile
ConvertJSONToSQL JSLTTransformJSON PutSnowflakeInternalStage
ConvertProtobuf JsonQueryElasticsearch PutSNS
ConvertRecord ListAzureBlobStorage PutSolrContentStream
CreateHadoopSequenceFile ListAzureBlobStorage_v12 PutSolrRecord
CryptographicHashAttribute ListAzureDataLakeStorage PutSplunk
CryptographicHashContent ListBoxFile PutSplunkHTTP
DecryptContent ListCDPObjectStore PutSQL
DecryptContentAge ListDatabaseTables PutSQS
DecryptContentCompatibility ListDropbox PutSyslog
DecryptContentPGP ListenBeats PutTCP
DeduplicateRecord ListenFTP PutUDP
DeleteAzureBlobStorage ListenGRPC PutWebSocket
DeleteAzureBlobStorage_v12 ListenGRPC PutZendeskTicket
DeleteAzureDataLakeStorage ListenHTTP QueryAirtableTable
DeleteByQueryElasticsearch ListenNetFlow QueryCassandra
DeleteCDPObjectStore ListenOTLP QueryDatabaseTable
DeleteDynamoDB ListenRELP QueryDatabaseTableRecord
DeleteGCSObject ListenSyslog QueryElasticsearchHttp
DeleteGridFS ListenTCP QueryRecord
DeleteHBaseCells ListenTCPRecord QuerySalesforceObject
DeleteHBaseRow ListenTrapSNMP QuerySolr
DeleteHDFS ListenUDP QuerySplunkIndexingStatus
DeleteS3Object ListenUDPRecord QueryWhois
DeleteSQS ListenWebSocket RemoveRecordField
DetectDuplicate ListFile ReplaceText
DistributeLoad ListFTP ReplaceTextWithMapping
DuplicateFlowFile ListGCSBucket ResizeImage
EncodeContent ListGoogleDrive RetryFlowFile
EncryptContent ListHDFS RouteHL7
EncryptContentAge ListS3 RouteOnAttribute
EncryptContentPGP ListSFTP RouteOnContent
EnforceOrder ListSmb RouteText
EvaluateJsonPath LogAttribute SampleRecord
EvaluateXPath LogMessage ScanAccumulo
EvaluateXQuery LookupAttribute ScanAttribute
ExecuteGroovyScript LookupRecord ScanContent
ExecuteInfluxDBQuery MergeContent ScanHBase
ExecuteProcess MergeRecord ScriptedFilterRecord
ExecuteScript ModifyCompression ScriptedPartitionRecord
ExecuteSQL ModifyHTMLElement ScriptedTransformRecord
ExecuteSQLRecord MonitorActivity ScriptedValidateRecord
ExecuteStateless MoveAzureDataLakeStorage ScrollElasticsearchHttp
ExecuteStreamCommand MoveHDFS SearchElasticsearch
ExtractAvroMetadata Notify SegmentContent
ExtractGrok PackageFlowFile SelectClouderaHiveQL
ExtractHL7Attributes PaginatedJsonQueryElasticsearch SelectHive3QL
ExtractImageMetadata ParseCEF
ExtractRecordSchema ParseEvtx SendTrapSNMP
ExtractText ParseSyslog SetSNMP
FetchAzureBlobStorage PartitionRecord SignContentPGP
FetchAzureBlobStorage_v12 PostHTTP SplitAvro
FetchAzureDataLakeStorage PublishAMQP SplitContent
FetchBoxFile PublishGCPubSub SplitJson
FetchCDPObjectStore PublishGCPubSubLite SplitRecord
FetchDistributedMapCache PublishJMS SplitText
FetchDropbox SplitXml
FetchElasticsearchHttp StartAwsPollyJob
FetchFile PublishKafka_2_6 StartAwsTextractJob
FetchFTP PublishKafka2CDP StartAwsTranscribeJob
FetchGCSObject PublishKafka2RecordCDP StartAwsTranslateJob
FetchGoogleDrive StartGcpVisionAnnotateFilesOperation
FetchGridFS StartGcpVisionAnnotateImagesOperation
FetchHBaseRow PublishKafkaRecord_2_6 StartSnowflakeIngest
FetchHDFS PublishMQTT TagS3Object
FetchParquet PublishSlack TailFile
FetchS3Object PutAccumuloRecord TransformXml
FetchSFTP PutAzureBlobStorage TriggerClouderaHiveMetaStoreEvent
FetchSmb PutAzureBlobStorage_v12 TriggerHiveMetaStoreEvent
FilterAttribute PutAzureCosmosDBRecord UnpackContent
FlattenJson PutAzureDataLakeStorage UpdateAttribute
ForkEnrichment PutAzureEventHub UpdateByQueryElasticsearch
ForkRecord PutAzureQueueStorage UpdateClouderaHiveTable
GenerateFlowFile PutAzureQueueStorage_v12 UpdateCounter
GenerateRecord PutBigQuery UpdateDatabaseTable
GenerateTableFetch PutBigQueryBatch UpdateDeltaLakeTable [Technical Preview]
GeoEnrichIP PutBigQueryStreaming UpdateHive3Table
GeoEnrichIPRecord PutBoxFile
GeohashRecord PutCassandraQL UpdateRecord
GetAsanaObject PutCassandraRecord ValidateCsv
GetAwsPollyJobStatus PutCDPObjectStore ValidateJson
GetAwsTextractJobStatus PutClouderaHiveQL ValidateRecord
GetAwsTranscribeJobStatus PutClouderaHiveStreaming ValidateXml
GetAwsTranslateJobStatus PutClouderaORC VerifyContentMAC
GetAzureEventHub PutCloudWatchMetric VerifyContentPGP
GetAzureQueueStorage PutCouchbaseKey Wait
GetAzureQueueStorage_v12 PutDatabaseRecord YandexTranslate
GetCouchbaseKey PutDistributedMapCache

NiFi 2.0 [Technical Preview]

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