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.

CFM 2.1.5 supports the following NiFi processors:

AttributesToCSV GetHBase PutDistributedMapCache
AttributesToJSON GetHDFS PutDynamoDB1
Base64EncodeContent GetHDFSFileInfo PutDynamoDBRecord
CalculateRecordStats GetHDFSSequenceFile PutElasticsearchHttp1
CaptureChangeMySQL GetHTMLElement PutElasticsearchHttpRecord
CompressContent1,2 GetHTTP PutElasticsearchJson
ConnectWebSocket GetHubSpot PutElasticsearchRecord
ConsumeAMQP GetIgniteCache PutEmail1
ConsumeAzureEventHub GetJMSQueue PutFile
ConsumeEWS GetJMSTopic PutFTP
ConsumeGCPubSub GetMongoRecord PutGCSObject
ConsumeGCPubSubLite GetSFTP PutGridFS
ConsumeJMS GetShopify PutHBaseCell1
ConsumeKafka_1_0 GetSNMP PutHBaseJSON
ConsumeKafka_2_0 GetSnowflakeIngestStatus (Technical Preview) PutHBaseRecord
ConsumeKafka_2_6 GetSolr PutHDFS
ConsumeKafka2CDP GetSplunk PutHive3QL
ConsumeKafka2RecordCDP GetSQS PutHive3Streaming
ConsumeKafkaRecord_1_0 GetTCP PutHiveQL
ConsumeKafkaRecord_2_0 GetTwitter PutHiveStreaming
ConsumeKafkaRecord_2_6 GetWorkdayReport PutHTMLElement
ConsumeKinesisStream GetZendesk PutIceberg (Technical Preview)
ConsumeMQTT1 HandleHttpRequest PutInfluxDB
ConsumeTwitter HandleHttpResponse PutJMS
ConsumeWindowsEventLog HashAttribute PutKinesisFirehose
ControlRate HashContent PutKinesisStream
ConvertAvroSchema IdentifyMimeType PutKudu
ConvertAvroToJSON InvokeAWSGatewayApi PutLambda
ConvertAvroToORC InvokeGRPC PutMongoRecord
ConvertAvroToParquet InvokeHTTP PutORC
ConvertCharacterSet InvokeScriptedProcessor PutParquet
ConvertCSVToAvro JoinEnrichment PutRecord
ConvertJSONToAvro JoltTransformJSON PutRiemann
ConvertJSONToSQL JoltTransformRecord PutS3Object
ConvertRecord JsonQueryElasticsearch PutSFTP
CreateHadoopSequenceFile ListAzureBlobStorage PutSmbFile
CryptographicHashAttribute ListAzureBlobStorage_v12 PutSnowflakeInternalStage (Technical Preview)
CryptographicHashContent ListAzureDataLakeStorage PutSNS
DecryptContentPGP ListBoxFile PutSolrContentStream
DeduplicateRecord ListCDPObjectStore PutSolrRecord
DeleteAzureBlobStorage ListDatabaseTables PutSplunk
DeleteAzureBlobStorage_v12 ListDropbox PutSplunkHTTP1
DeleteAzureDataLakeStorage ListenBeats PutSQL
DeleteByQueryElasticsearch ListenFTP PutSQS
DeleteCDPObjectStore ListenGRPC PutSyslog
DeleteDynamoDB ListenHTTP PutTCP
DeleteGCSObject ListenRELP PutUDP
DeleteGridFS ListenSyslog PutWebSocket1
DeleteHBaseCells ListenTCP QueryAirtableTable
DeleteHBaseRow ListenTCPRecord QueryCassandra
DeleteHDFS ListenTrapSNMP QueryDatabaseTable
DeleteS3Object ListenUDP QueryDatabaseTableRecord
DeleteSQS ListenUDPRecord QueryElasticsearchHttp
DetectDuplicate ListenWebSocket QueryRecord
DistributeLoad ListFile QuerySalesforceObject
DuplicateFlowFile ListFTP QuerySolr
EncryptContent2 ListGCSBucket QuerySplunkIndexingStatus
EncryptContentPGP ListGoogleDrive QueryWhois
EnforceOrder ListHDFS ReplaceText1
EvaluateJsonPath ListS3 ReplaceTextWithMapping
EvaluateXPath ListSFTP ResizeImage
EvaluateXQuery ListSmb RetryFlowFile
ExecuteGroovyScript LogAttribute RouteHL7
ExecuteInfluxDBQuery LogMessage RouteOnAttribute
ExecuteProcess LookupAttribute RouteOnContent
ExecuteScript LookupRecord RouteText
ExecuteSQL MergeContent1 SampleRecord1
ExecuteSQLRecord MergeRecord ScanAccumulo
ExecuteStateless ModifyHTMLElement ScanAttribute
ExecuteStreamCommand MonitorActivity ScanContent
ExtractAvroMetadata MoveAzureDataLakeStorage ScanHBase
ExtractGrok MoveHDFS ScriptedFilterRecord
ExtractHL7Attributes Notify ScriptedPartitionRecord
ExtractImageMetadata PaginatedJsonQueryElasticsearch ScriptedTransformRecord
ExtractText ParseCEF ScriptedValidateRecord
FetchAzureBlobStorage ParseEvtx ScrollElasticsearchHttp
FetchAzureBlobStorage_v12 ParseSyslog SearchElasticsearch
FetchAzureDataLakeStorage PartitionRecord SegmentContent
FetchBoxFile PostHTTP SelectHive3QL
FetchCDPObjectStore PublishAMQP1 SelectHiveQL
FetchDistributedMapCache PublishGCPubSub1 SendTrapSNMP
FetchDropbox PublishGCPubSubLite SetSNMP
FetchElasticsearchHttp PublishJMS1 SignContentPGP
FetchFile PublishKafka_1_0 SplitAvro1
FetchFTP PublishKafka_2_0 SplitContent1
FetchGCSObject PublishKafka_2_6 SplitJson1
FetchGoogleDrive PublishKafka2CDP SplitRecord
FetchGridFS PublishKafka2RecordCDP SplitText1
FetchHBaseRow PublishKafkaRecord_1_0 SplitXml1
FetchHDFS PublishKafkaRecord_2_0 StartSnowflakeIngest (Technical Preview)
FetchParquet PublishKafkaRecord_2_6 TagS3Object
FetchS3Object PublishMQTT1 TailFile
FetchSFTP PutAccumuloRecord TransformXml
FetchSmb PutAzureBlobStorage UnpackContent
FlattenJson PutAzureBlobStorage_v12 UpdateAttribute
ForkEnrichment PutAzureCosmosDBRecord1 UpdateByQueryElasticsearch
ForkRecord PutAzureDataLakeStorage UpdateCounter
GenerateFlowFile PutAzureEventHub1 UpdateDatabaseTable
GenerateTableFetch PutAzureQueueStorage UpdateHive3Table
GeoEnrichIP PutBigQuery UpdateHiveTable
GeoEnrichIPRecord PutBigQueryBatch UpdateRecord
GeohashRecord PutBigQueryStreaming1 ValidateCsv
GetAzureEventHub PutCassandraQL1 ValidateRecord
GetAzureQueueStorage PutCassandraRecord ValidateXml
GetCouchbaseKey1 PutCDPObjectStore VerifyContentPGP
GetElasticsearch PutCloudWatchMetric Wait
GetFile PutCouchbaseKey1 YandexTranslate
GetFTP PutDatabaseRecord

Footnotes

  • 1 – indicates a memory intensive processor
  • 2 – indicates a CPU intensive processor