Supported NiFi processors

Cloudera Flow Management (CFM) is shipped with Apache NiFi and includes a set of processors, most of which are supported by Cloudera. You should be familiar with the available supported processors, and avoid using any unsupported processors in production environments.

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.

AttributesToCSV GetGcpVisionAnnotateImagesOperationStatus PutDropbox
AttributesToJSON GetHBase PutDynamoDB
Base64EncodeContent GetHDFS PutDynamoDBRecord
CalculateRecordStats GetHDFSFileInfo PutElasticsearchHttp1
CaptureChangeMySQL GetHDFSSequenceFile PutElasticsearchHttpRecord1
CompressContent1,2 GetHTMLElement PutElasticsearchJson
ConnectWebSocket GetHTTP PutElasticsearchRecord1
ConsumeAMQP GetHubSpot PutEmail
ConsumeAzureEventHub GetIgniteCache PutFile
ConsumeEWS GetJiraIssue PutFTP1
ConsumeGCPubSub GetJMSQueue PutGCSObject
ConsumeGCPubSubLite GetJMSTopic PutGoogleDrive
ConsumeJMS GetMongoRecord PutGridFS
ConsumeKafka_1_0 GetSFTP PutHBaseCell
ConsumeKafka_2_0 GetShopify PutHBaseJSON
ConsumeKafka_2_6 GetSNMP PutHBaseRecord1
ConsumeKafka2CDP GetSnowflakeIngestStatus (Technical Preview) PutHDFS
ConsumeKafka2RecordCDP GetSolr PutHive3QL
ConsumeKafkaRecord_1_0 GetSplunk PutHive3Streaming
ConsumeKafkaRecord_2_0 GetSQS PutHiveQL
ConsumeKafkaRecord_2_6 GetTCP PutHiveStreaming
ConsumeKinesisStream GetTwitter PutHTMLElement
ConsumeMQTT1 GetWorkdayReport PutIceberg
ConsumeTwitter GetZendesk PutInfluxDB
ConsumeWindowsEventLog HandleHttpRequest PutIoTDBRecord
ControlRate HandleHttpResponse PutJMS1
ConvertAvroSchema HashAttribute PutKinesisFirehose
ConvertAvroToJSON HashContent PutKinesisStream
ConvertAvroToORC IdentifyMimeType PutKudu
ConvertAvroToParquet InvokeAWSGatewayApi PutLambda
ConvertCharacterSet InvokeGRPC PutMongoRecord
ConvertCSVToAvro InvokeHTTP PutORC1
ConvertJSONToAvro InvokeScriptedProcessor PutParquet
ConvertJSONToSQL JoinEnrichment PutRecord
ConvertProtobuf JoltTransformJSON PutRedisHashRecord (Technical Preview)
ConvertRecord JoltTransformRecord PutRiemann
CreateHadoopSequenceFile JSLTTransformJSON PutS3Object
CryptographicHashAttribute JsonQueryElasticsearch PutSalesforceObject
CryptographicHashContent ListAzureBlobStorage PutSFTP
DecryptContent ListAzureBlobStorage_v12 PutSmbFile
DecryptContentCompatibility ListAzureDataLakeStorage PutSnowflakeInternalStage (Technical Preview)
DecryptContentPGP ListBoxFile PutSNS
DeduplicateRecord ListCDPObjectStore PutSolrContentStream
DeleteAzureBlobStorage ListDatabaseTables PutSolrRecord
DeleteAzureBlobStorage_v12 ListDropbox PutSplunk
DeleteAzureDataLakeStorage ListenBeats PutSplunkHTTP
DeleteByQueryElasticsearch ListenFTP PutSQL
DeleteCDPObjectStore ListenGRPC* PutSQS1
DeleteDynamoDB ListenGRPC* PutSyslog
DeleteGCSObject ListenHTTP PutTCP
DeleteGridFS ListenRELP PutUDP
DeleteHBaseCells ListenSyslog PutWebSocket1
DeleteHBaseRow ListenTCP QueryAirtableTable
DeleteHDFS ListenTCPRecord QueryCassandra
DeleteS3Object ListenTrapSNMP QueryDatabaseTable1
DeleteSQS ListenUDP QueryDatabaseTableRecord
DetectDuplicate ListenUDPRecord QueryElasticsearchHttp
DistributeLoad ListenWebSocket QueryRecord
DuplicateFlowFile ListFile QuerySalesforceObject
EncodeContent ListFTP QuerySolr
EncryptContent2 ListGCSBucket QuerySplunkIndexingStatus
EncryptContentPGP ListGoogleDrive QueryWhois
EnforceOrder ListHDFS ReplaceText
EvaluateJsonPath ListS3 ReplaceTextWithMapping
EvaluateXPath ListSFTP ResizeImage1
EvaluateXQuery ListSmb RetryFlowFile
ExecuteGroovyScript LogAttribute RouteHL7
ExecuteInfluxDBQuery LogMessage RouteOnAttribute
ExecuteProcess LookupAttribute RouteOnContent
ExecuteScript LookupRecord RouteText
ExecuteSQL MergeContent SampleRecord
ExecuteSQLRecord MergeRecord1 ScanAccumulo
ExecuteStateless1,2 ModifyHTMLElement ScanAttribute1
ExecuteStreamCommand MonitorActivity ScanContent
ExtractAvroMetadata MoveAzureDataLakeStorage ScanHBase
ExtractGrok MoveHDFS ScriptedFilterRecord
ExtractHL7Attributes Notify ScriptedPartitionRecord
ExtractImageMetadata PaginatedJsonQueryElasticsearch ScriptedTransformRecord
ExtractText ParseCEF1 ScriptedValidateRecord
FetchAzureBlobStorage ParseEvtx ScrollElasticsearchHttp
FetchAzureBlobStorage_v12 ParseSyslog SearchElasticsearch
FetchAzureDataLakeStorage PartitionRecord SegmentContent
FetchBoxFile PostHTTP SelectHive3QL1
FetchCDPObjectStore PublishAMQP SelectHiveQL
FetchDistributedMapCache PublishGCPubSub1 SendTrapSNMP
FetchDropbox PublishGCPubSubLite1 SetSNMP
FetchElasticsearchHttp PublishJMS1 SignContentPGP
FetchFile PublishKafka_1_0 SplitAvro
FetchFTP PublishKafka_2_0 SplitContent
FetchGCSObject PublishKafka_2_6 SplitJson1
FetchGoogleDrive PublishKafka2CDP SplitRecord1
FetchGridFS PublishKafka2RecordCDP SplitText1
FetchHBaseRow PublishKafkaRecord_1_0 SplitXml
FetchHDFS PublishKafkaRecord_2_0 StartGcpVisionAnnotateFilesOperation
FetchParquet PublishKafkaRecord_2_6 StartGcpVisionAnnotateImagesOperation
FetchS3Object PublishMQTT StartSnowflakeIngest (Technical Preview)
FetchSFTP PutAccumuloRecord1 TagS3Object
FetchSmb PutAzureBlobStorage TailFile
FlattenJson PutAzureBlobStorage_v12 TransformXml
ForkEnrichment PutAzureCosmosDBRecord TriggerHiveMetaStoreEvent
ForkRecord PutAzureDataLakeStorage1 UnpackContent
GenerateFlowFile PutAzureEventHub UpdateAttribute
GenerateTableFetch PutAzureQueueStorage1 UpdateByQueryElasticsearch
GeoEnrichIP PutBigQuery UpdateCounter
GeoEnrichIPRecord PutBigQueryBatch UpdateDatabaseTable
GeohashRecord PutBigQueryStreaming UpdateDeltaLakeTable (Technical Preview)
GetAsanaObject PutBoxFile UpdateHive3Table
GetAzureEventHub PutCassandraQL1 UpdateHiveTable
GetAzureQueueStorage PutCassandraRecord1 UpdateRecord
GetCouchbaseKey1 PutCDPObjectStore ValidateCsv
GetElasticsearch PutCloudWatchMetric ValidateRecord
GetFile PutCouchbaseKey ValidateXml
GetFTP PutDatabaseRecord1 VerifyContentPGP
GetGcpVisionAnnotateFilesOperationStatus PutDistributedMapCache Wait
YandexTranslate

Footnotes

  • 1 – indicates a memory intensive processor
  • 2 – indicates a CPU intensive processor
  • * – there are two ListenGRPC processors available, one from Apache and another one from Cloudera