Supported NiFi processors
This release is based on Apache NiFi 1.25 and 2.0.0 and includes a set of processors, most of which are supported by Cloudera Support.
You should be familiar with the available supported processors and avoid using any unsupported processors in production environments.
While 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, incomplete test case coverage, community declaration of non-production readiness, or feature deviation from Cloudera best practices.
NiFi 1.25
| AttributesToCSV | GetElasticsearch | PutDropbox |
| AttributesToJSON | GetFile | PutDynamoDB1 |
| Base64EncodeContent | GetFTP | PutDynamoDBRecord |
| CalculateParquetOffsets | GetGcpVisionAnnotateFilesOperationStatus | PutElasticsearchHttp1 |
| CalculateParquetRowGroupOffsets | GetGcpVisionAnnotateImagesOperationStatus | PutElasticsearchHttpRecord |
| CalculateRecordStats | GetHBase | PutElasticsearchJson |
| CaptureChangeDebeziumDB2 [Technical Preview] | GetHDFS | PutElasticsearchRecord |
| CaptureChangeDebeziumMySQL [Technical Preview] | GetHDFSFileInfo | PutEmail1 |
| CaptureChangeDebeziumOracle [Technical Preview] | GetHDFSSequenceFile | PutFile |
| CaptureChangeDebeziumPostgreSQL [Technical Preview] | GetHTMLElement | PutFTP |
| CaptureChangeDebeziumSQLServer [Technical Preview] | GetHTTP | PutGCSObject |
| CaptureChangeMySQL | GetHubSpot | PutGoogleDrive |
| CompressContent12 | GetIgniteCache | PutGridFS |
| ConnectWebSocket | GetJiraIssue | PutHBaseCell1 |
| ConsumeAMQP | GetJMSQueue | PutHBaseJSON |
| ConsumeAzureEventHub | GetJMSTopic | PutHBaseRecord |
| ConsumeElasticsearch | GetMongoRecord | PutHDFS |
| ConsumeEWS | GetSFTP | PutHive3QL |
| ConsumeGCPubSub | GetShopify | PutHive3Streaming |
| ConsumeGCPubSubLite | GetSNMP | PutHiveQL |
| ConsumeJMS | GetSnowflakeIngestStatus | PutHiveStreaming |
| ConsumeKafka_1_0 | GetSolr | PutHTMLElement |
| ConsumeKafka_2_0 | GetSplunk | PutIceberg |
| ConsumeKafka_2_6 | GetSQS | PutIcebergCDC [Technical Preview] |
| ConsumeKafka2CDP | GetTCP | PutInfluxDB |
| ConsumeKafka2RecordCDP | GetTwitter | PutJiraIssue |
| ConsumeKafkaRecord_1_0 | GetWorkdayReport | PutJMS |
| ConsumeKafkaRecord_2_0 | GetZendesk | PutKinesisFirehose |
| ConsumeKafkaRecord_2_6 | HandleHttpRequest | PutKinesisStream |
| ConsumeKinesisStream | HandleHttpResponse | PutKudu |
| ConsumeMQTT | HashAttribute | PutLambda |
| ConsumeTwitter | HashContent | PutMongoRecord |
| ConsumeWindowsEventLog | IdentifyMimeType | PutORC |
| ControlRate | InvokeAWSGatewayApi | PutParquet |
| ConvertAvroSchema | InvokeGRPC | PutRecord |
| ConvertAvroToJSON | InvokeGRPC | PutRedisHashRecord [Technical Preview] |
| ConvertAvroToORC | InvokeHTTP | PutRiemann |
| ConvertAvroToParquet | InvokeScriptedProcessor | PutS3Object |
| ConvertCharacterSet | JoinEnrichment | PutSalesforceObject |
| ConvertCSVToAvro | JoltTransformJSON | PutSFTP |
| ConvertJSONToAvro | JoltTransformRecord | PutSmbFile |
| ConvertJSONToSQL | JSLTTransformJSON | PutSnowflakeInternalStage |
| ConvertProtobuf | JsonQueryElasticsearch | PutSNS |
| ConvertRecord | ListAzureBlobStorage | PutSolrContentStream |
| CreateHadoopSequenceFile | ListAzureBlobStorage_v12 | PutSolrRecord |
| CryptographicHashAttribute | ListAzureDataLakeStorage | PutSplunk |
| CryptographicHashContent | ListBoxFile | PutSplunkHTTP1 |
| DecryptContent | ListCDPObjectStore | PutSQL |
| DecryptContentAge | ListDatabaseTables | PutSQS |
| DecryptContentCompatibility | ListDropbox | PutSyslog |
| DecryptContentPGP | ListenBeats | PutTCP |
| DeduplicateRecord | ListenFTP | PutUDP |
| DeleteAzureBlobStorage | ListenGRPC | PutWebSocket1 |
| 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 | ReplaceText1 |
| DistributeLoad | ListFTP | ReplaceTextWithMapping |
| DuplicateFlowFile | ListGCSBucket | ResizeImage |
| EncodeContent | ListGoogleDrive | RetryFlowFile |
| EncryptContent | ListHDFS | RouteHL7 |
| EncryptContentAge | ListS3 | RouteOnAttribute |
| EncryptContentPGP | ListSFTP | RouteOnContent |
| EnforceOrder | ListSmb | RouteText |
| EvaluateJsonPath | LogAttribute | SampleRecord1 |
| EvaluateXPath | LogMessage | ScanAccumulo |
| EvaluateXQuery | LookupAttribute | ScanAttribute |
| ExecuteGroovyScript | LookupRecord | ScanContent |
| ExecuteInfluxDBQuery | MergeContent1 | 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 | SelectHiveQL |
| ExtractRecordSchema | ParseEvtx | SendTrapSNMP |
| ExtractText | ParseSyslog | SetSNMP |
| FetchAzureBlobStorage | PartitionRecord | SignContentPGP |
| FetchAzureBlobStorage_v12 | PostHTTP | SplitAvro1 |
| FetchAzureDataLakeStorage | PublishAMQP1 | SplitContent1 |
| FetchBoxFile | PublishGCPubSub1 | SplitJson1 |
| FetchCDPObjectStore | PublishGCPubSubLite | SplitRecord |
| FetchDistributedMapCache | PublishJMS1 | SplitText1 |
| FetchDropbox | PublishKafka_1_0 | SplitXml1 |
| FetchElasticsearchHttp | PublishKafka_2_0 | StartAwsPollyJob |
| FetchFile | PublishKafka_2_6 | StartAwsTextractJob |
| FetchFTP | PublishKafka2CDP | StartAwsTranscribeJob |
| FetchGCSObject | PublishKafka2RecordCDP | StartAwsTranslateJob |
| FetchGoogleDrive | PublishKafkaRecord_1_0 | StartGcpVisionAnnotateFilesOperation |
| FetchGridFS | PublishKafkaRecord_2_0 | StartGcpVisionAnnotateImagesOperation |
| FetchHBaseRow | PublishKafkaRecord_2_6 | StartSnowflakeIngest |
| FetchHDFS | PublishMQTT1 | TagS3Object |
| FetchParquet | PublishSlack | TailFile |
| FetchS3Object | PutAccumuloRecord | TransformXml |
| FetchSFTP | PutAzureBlobStorage | TriggerClouderaHiveMetaStoreEvent |
| FetchSmb | PutAzureBlobStorage_v12 | TriggerHiveMetaStoreEvent |
| FilterAttribute | PutAzureCosmosDBRecord1 | UnpackContent |
| FlattenJson | PutAzureDataLakeStorage | UpdateAttribute |
| ForkEnrichment | PutAzureEventHub1 | UpdateByQueryElasticsearch |
| ForkRecord | PutAzureQueueStorage | UpdateClouderaHiveTable |
| GenerateFlowFile | PutAzureQueueStorage_v12 | UpdateCounter |
| GenerateRecord | PutBigQuery | UpdateDatabaseTable |
| GenerateTableFetch | PutBigQueryBatch | UpdateDeltaLakeTable [Technical Preview] |
| GeoEnrichIP | PutBigQueryStreaming1 | UpdateHive3Table |
| GeoEnrichIPRecord | PutBoxFile | UpdateHiveTable |
| GeohashRecord | PutCassandraQL1 | UpdateRecord |
| GetAsanaObject | PutCassandraRecord | ValidateCsv |
| GetAwsPollyJobStatus | PutCDPObjectStore | ValidateJson |
| GetAwsTextractJobStatus | PutClouderaHiveQL | ValidateRecord |
| GetAwsTranscribeJobStatus | PutClouderaHiveStreaming | ValidateXml |
| GetAwsTranslateJobStatus | PutClouderaORC | VerifyContentMAC |
| GetAzureEventHub | PutCloudWatchMetric | VerifyContentPGP |
| GetAzureQueueStorage | PutCouchbaseKey1 | Wait |
| GetAzureQueueStorage_v12 | PutDatabaseRecord | YandexTranslate |
| GetCouchbaseKey | PutDistributedMapCache |
Footnotes
- 1 – indicates a memory intensive processor
- 2 – indicates a CPU intensive processor
NiFi 2.0
| 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 |
