Supported NiFi processors
This release is based on Apache NiFi versions 1.28 and 2.0, with added support for Python processors in NiFi 2. Most processors included in these NiFi versions are supported by Cloudera.
To ensure optimal performance and reliable support, it is crucial to use only supported processors and avoid deploying unsupported ones in production environments.
Additional processors are developed and tested by the community but are not officially supported by Cloudera. Processors may be excluded for various reasons, including insufficient reliability, incomplete test coverage, community declaration of non-production readiness, or deviations from Cloudera best practices.
By adhering to the above guidelines, you can maintain stable and reliable workflows in your production environments.
NiFi 1.28
| AttributesToCSV | GetElasticsearch | PutDropbox |
| AttributesToJSON | GetFile | PutDynamoDB |
| Base64EncodeContent | GetFTP | PutDynamoDBRecord |
| CalculateParquetOffsets | GetGcpVisionAnnotateFilesOperationStatus | PutElasticsearchHttp1 |
| CalculateParquetRowGroupOffsets | GetGcpVisionAnnotateImagesOperationStatus | PutElasticsearchHttpRecord1 |
| CalculateRecordStats | GetHBase | PutElasticsearchJson |
| CaptureChangeDebeziumDB2 [Technical Preview] | GetHDFS | PutElasticsearchRecord1 |
| CaptureChangeDebeziumMySQL [Technical Preview] | GetHDFSFileInfo | PutEmail |
| CaptureChangeDebeziumOracle [Technical Preview] | GetHDFSSequenceFile | PutFile |
| CaptureChangeDebeziumPostgreSQL [Technical Preview] | GetHTMLElement | PutFTP1 |
| CaptureChangeDebeziumSQLServer [Technical Preview] | GetHTTP | PutGCSObject |
| CaptureChangeMySQL | GetHubSpot | PutGoogleDrive |
| CompressContent1, 2 | GetIgniteCache | PutGridFS |
| ConnectWebSocket | GetJiraIssue | PutHBaseCell |
| ConsumeAMQP | GetJMSQueue | PutHBaseJSON |
| ConsumeAzureEventHub | GetJMSTopic | PutHBaseRecord1 |
| 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 | PutJMS1 |
| ConsumeKafkaRecord_2_0 | GetZendesk | PutKinesisFirehose |
| ConsumeKafkaRecord_2_6 | HandleHttpRequest | PutKinesisStream |
| ConsumeKinesisStream | HandleHttpResponse | PutKudu |
| ConsumeMQTT1 | HashAttribute | PutLambda |
| ConsumeTwitter | HashContent | PutMongoRecord |
| ConsumeWindowsEventLog | IdentifyMimeType | PutORC1 |
| 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 | PutSplunkHTTP |
| DecryptContent | ListCDPObjectStore | PutSQL |
| DecryptContentAge | ListDatabaseTables | PutSQS1 |
| DecryptContentCompatibility | ListDropbox | PutSyslog |
| DecryptContentPGP | ListenBeats | PutTCP |
| DeduplicateRecord | ListenFTP | PutUDP |
| DeleteAzureBlobStorage | ListenGRPC | PutWebSocket |
| DeleteAzureBlobStorage_v12 | ListenGRPC | PutZendeskTicket |
| DeleteAzureDataLakeStorage | ListenHTTP | QueryAirtableTable |
| DeleteByQueryElasticsearch | ListenNetFlow | QueryCassandra |
| DeleteCDPObjectStore | ListenOTLP | QueryDatabaseTable1 |
| 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 | ResizeImage1 |
| EncodeContent | ListGoogleDrive | RetryFlowFile |
| EncryptContent2 | ListHDFS | RouteHL7 |
| EncryptContentAge | ListS3 | RouteOnAttribute |
| EncryptContentPGP | ListSFTP | RouteOnContent |
| EnforceOrder | ListSmb | RouteText |
| EvaluateJsonPath | LogAttribute | SampleRecord |
| EvaluateXPath | LogMessage | ScanAccumulo |
| EvaluateXQuery | LookupAttribute | ScanAttribute1 |
| ExecuteGroovyScript | LookupRecord | ScanContent |
| ExecuteInfluxDBQuery | MergeContent | ScanHBase |
| ExecuteProcess | MergeRecord1 | ScriptedFilterRecord |
| ExecuteScript | ModifyCompression | ScriptedPartitionRecord |
| ExecuteSQL | ModifyHTMLElement | ScriptedTransformRecord |
| ExecuteSQLRecord | MonitorActivity | ScriptedValidateRecord |
| ExecuteStateless12 | MoveAzureDataLakeStorage | ScrollElasticsearchHttp |
| ExecuteStreamCommand | MoveHDFS | SearchElasticsearch |
| ExtractAvroMetadata | Notify | SegmentContent |
| ExtractGrok | PackageFlowFile | SelectClouderaHiveQL |
| ExtractHL7Attributes | PaginatedJsonQueryElasticsearch | SelectHive3QL1 |
| ExtractImageMetadata | ParseCEF1 | SelectHiveQL |
| ExtractRecordSchema | ParseEvtx | SendTrapSNMP |
| ExtractText | ParseSyslog | SetSNMP |
| FetchAzureBlobStorage | PartitionRecord | SignContentPGP |
| FetchAzureBlobStorage_v12 | PostHTTP | SplitAvro |
| FetchAzureDataLakeStorage | PublishAMQP | SplitContent |
| FetchBoxFile | PublishGCPubSub1 | SplitJson1 |
| FetchCDPObjectStore | PublishGCPubSubLite1 | SplitRecord1 |
| FetchDistributedMapCache | PublishJMS1 | SplitText1 |
| FetchDropbox | PublishKafka_1_0 | SplitXml |
| 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 | PublishMQTT | TagS3Object |
| FetchParquet | PublishSlack | TailFile |
| FetchS3Object | PutAccumuloRecord1 | TransformXml |
| FetchSFTP | PutAzureBlobStorage | TriggerClouderaHiveMetaStoreEvent |
| FetchSmb | PutAzureBlobStorage_v12 | TriggerHiveMetaStoreEvent |
| FilterAttribute | PutAzureCosmosDBRecord | UnpackContent |
| FlattenJson | PutAzureDataLakeStorage1 | UpdateAttribute |
| ForkEnrichment | PutAzureEventHub | UpdateByQueryElasticsearch |
| ForkRecord | PutAzureQueueStorage1 | UpdateClouderaHiveTable |
| GenerateFlowFile | PutAzureQueueStorage_v12 | UpdateCounter |
| GenerateRecord | PutBigQuery | UpdateDatabaseTable |
| GenerateTableFetch | PutBigQueryBatch | UpdateDeltaLakeTable [Technical Preview] |
| GeoEnrichIP | PutBigQueryStreaming | UpdateHive3Table |
| GeoEnrichIPRecord | PutBoxFile | UpdateHiveTable |
| GeohashRecord | PutCassandraQL1 | UpdateRecord |
| GetAsanaObject | PutCassandraRecord1 | ValidateCsv |
| GetAwsPollyJobStatus | PutCDPObjectStore | ValidateJson |
| GetAwsTextractJobStatus | PutClouderaHiveQL | ValidateRecord |
| GetAwsTranscribeJobStatus | PutClouderaHiveStreaming | ValidateXml |
| GetAwsTranslateJobStatus | PutClouderaORC | VerifyContentMAC |
| GetAzureEventHub | PutCloudWatchMetric | VerifyContentPGP |
| GetAzureQueueStorage | PutCouchbaseKey | Wait |
| GetAzureQueueStorage_v12 | PutDatabaseRecord1 | YandexTranslate |
| GetCouchbaseKey1 | PutDistributedMapCache |
Footnotes
- 1 – indicates a memory-intensive processor
- 2 – indicates a CPU-intensive processor
NiFi 2.0
| AttributesToCSV | GetElasticsearch | PutFile |
| AttributesToJSON | GetFile | PutFTP1 |
| CalculateParquetOffsets | GetFTP | PutGCSObject |
| CalculateParquetRowGroupOffsets | GetGcpVisionAnnotateFilesOperationStatus | PutGoogleDrive |
| CalculateRecordStats | GetGcpVisionAnnotateImagesOperationStatus | PutGridFS |
| CaptureChangeDebeziumDB2 [Technical Preview] | GetHBase | PutHBaseCell |
| CaptureChangeDebeziumMySQL [Technical Preview] | GetHDFS | PutHBaseJSON |
| CaptureChangeDebeziumOracle [Technical Preview] | GetHDFSFileInfo | PutHBaseRecord1 |
| CaptureChangeDebeziumPostgreSQL [Technical Preview] | GetHDFSSequenceFile | PutHDFS |
| CaptureChangeDebeziumSQLServer [Technical Preview] | GetHubSpot | PutHive3QL |
| CaptureChangeMySQL | GetJiraIssue | PutHive3Streaming |
| ChunkDocument [Technical Preview] | GetMongoRecord | PutIceberg |
| CompressContent1, 2 | GetSFTP | PutIcebergCDC [Technical Preview] |
| ConnectWebSocket | GetShopify | PutJiraIssue |
| ConsumeAMQP | GetSNMP | PutKinesisFirehose |
| ConsumeAzureEventHub | GetSnowflakeIngestStatus | PutKinesisStream |
| ConsumeElasticsearch | GetSolr | PutKudu |
| ConsumeGCPubSub | GetSplunk | PutLambda |
| ConsumeGCPubSubLite | GetSQS | PutMongoBulkOperations |
| ConsumeJMS | GetWorkdayReport | PutMongoRecord |
| ConsumeKafka_2_6 | GetZendesk | PutORC1 |
| ConsumeKafka2CDP | HandleHttpRequest | PutParquet |
| ConsumeKafka2RecordCDP | HandleHttpResponse | PutPinecone [Technical Preview] |
| ConsumeKafkaRecord_2_6 | IdentifyMimeType | PutPLC [Technical Preview] |
| ConsumeKinesisStream | InvokeAWSGatewayApi | PutRecord |
| ConsumeMQTT1 | InvokeGRPC | PutRedisHashRecord [Technical Preview] |
| ConsumePLC [Technical Preview] | InvokeHTTP | PutS3Object |
| ConsumeSlack | InvokeScriptedProcessor | PutSalesforceObject |
| ConsumeTwitter | JoinEnrichment | PutSFTP |
| ConsumeWindowsEventLog | JoltTransformJSON | PutSmbFile |
| ControlRate | JoltTransformRecord | PutSnowflakeInternalStage |
| ConvertAvroToJSON | JSLTTransformJSON | PutSNS |
| ConvertAvroToParquet | JsonQueryElasticsearch | PutSolrContentStream |
| ConvertCharacterSet | ListAzureBlobStorage_v12 | PutSolrRecord |
| ConvertJSONToSQL | ListAzureDataLakeStorage | PutSplunk |
| ConvertProtobuf | ListBoxFile | PutSplunkHTTP |
| ConvertRecord | ListCDPObjectStore | PutSQL |
| CopyAzureBlobStorage_v12 | ListDatabaseTables | PutSQS1 |
| CreateHadoopSequenceFile | ListDropbox | PutSyslog |
| CryptographicHashContent | ListenBeats | PutTCP |
| DecryptContent | ListenFTP | PutUDP |
| DecryptContentAge | ListenGRPC | PutWebSocket |
| DecryptContentCompatibility | ListenHTTP | PutZendeskTicket |
| DecryptContentPGP | ListenNetFlow | QueryAirtableTable |
| DeduplicateRecord | ListenOTLP | QueryCassandra |
| DeleteAzureBlobStorage_v12 | ListenRELP | QueryChroma [Technical Preview] |
| DeleteAzureDataLakeStorage | ListenSlack | QueryDatabaseTable1 |
| DeleteByQueryElasticsearch | ListenSyslog | QueryDatabaseTableRecord |
| DeleteCDPObjectStore | ListenTCP | QueryPinecone [Technical Preview] |
| DeleteDynamoDB | ListenTCPRecord | QueryRecord |
| DeleteGCSObject | ListenTrapSNMP | QuerySalesforceObject |
| DeleteGridFS | ListenUDP | QuerySolr |
| DeleteHBaseCells | ListenUDPRecord | QuerySplunkIndexingStatus |
| DeleteHBaseRow | ListenWebSocket | QueryWhois |
| DeleteHDFS | ListFile | RemoveRecordField |
| DeleteS3Object | ListFTP | RenameRecordField |
| DeleteSQS | ListGCSBucket | ReplaceText |
| DetectDuplicate | ListGoogleDrive | ReplaceTextWithMapping |
| DistributeLoad | ListHDFS | ResizeImage1 |
| DuplicateFlowFile | ListS3 | RetryFlowFile |
| EncodeContent | ListSFTP | RouteHL7 |
| EncryptContentAge | ListSmb | RouteOnAttribute |
| EncryptContentPGP | LogAttribute | RouteOnContent |
| EnforceOrder | LogMessage | RouteText |
| EvaluateJsonPath | LookupAttribute | SampleRecord |
| EvaluateXPath | LookupRecord | ScanAccumulo |
| EvaluateXQuery | MergeContent | ScanAttribute1 |
| ExecuteGroovyScript | MergeRecord1 | ScanContent |
| ExecuteProcess | ModifyCompression | ScanHBase |
| ExecuteScript | MonitorActivity | ScriptedFilterRecord |
| ExecuteSQL | MoveAzureDataLakeStorage | ScriptedPartitionRecord |
| ExecuteSQLRecord | MoveHDFS | ScriptedTransformRecord |
| ExecuteStateless1, 2 | Notify | ScriptedValidateRecord |
| ExecuteStreamCommand | PackageFlowFile | SearchElasticsearch |
| ExtractAvroMetadata | PaginatedJsonQueryElasticsearch | SegmentContent |
| ExtractGrok | ParseCEF1 | SelectClouderaHiveQL |
| ExtractHL7Attributes | ParseDocument [Technical Preview] | SelectHive3QL1 |
| ExtractImageMetadata | ParseEvtx | SendTrapSNMP |
| ExtractRecordSchema | ParseSyslog | SetSNMP |
| ExtractText | PartitionRecord | SignContentPGP |
| FetchAzureBlobStorage_v12 | PromptChatGPT [Technical Preview] | SplitAvro |
| FetchAzureDataLakeStorage | PublishAMQP | SplitContent |
| FetchBoxFile | PublishGCPubSub1 | SplitJson1 |
| FetchCDPObjectStore | PublishGCPubSubLite1 | SplitRecord1 |
| FetchDistributedMapCache | PublishJMS1 | SplitText1 |
| FetchDropbox | PublishKafka_2_6 | SplitXml |
| FetchFile | PublishKafka2CDP | StartAwsPollyJob |
| FetchFTP | PublishKafka2RecordCDP | StartAwsTextractJob |
| FetchGCSObject | PublishKafkaRecord_2_6 | StartAwsTranscribeJob |
| FetchGoogleDrive | PublishMQTT | StartAwsTranslateJob |
| FetchGridFS | PublishSlack | StartGcpVisionAnnotateFilesOperation |
| FetchHBaseRow | PutAccumuloRecord1 | StartGcpVisionAnnotateImagesOperation |
| FetchHDFS | PutAzureBlobStorage_v12 | StartSnowflakeIngest |
| FetchParquet | PutAzureCosmosDBRecord | TagS3Object |
| FetchPLC [Technical Preview] | PutAzureDataLakeStorage1 | TailFile |
| FetchS3Object | PutAzureEventHub | TransformXml |
| FetchSFTP | PutAzureQueueStorage_v12 | TriggerClouderaHiveMetaStoreEvent |
| FetchSmb | PutBigQuery | TriggerHiveMetaStoreEvent |
| FilterAttribute | PutBoxFile | UnpackContent |
| FlattenJson | PutCassandraQL1 | UpdateAttribute |
| ForkEnrichment | PutCassandraRecord1 | UpdateByQueryElasticsearch |
| ForkRecord | PutCDPObjectStore | UpdateClouderaHiveTable |
| GenerateFlowFile | PutChroma [Technical Preview] | UpdateCounter |
| GenerateRecord | PutClouderaHiveQL | UpdateDatabaseTable |
| GenerateTableFetch | PutClouderaHiveStreaming | UpdateDeltaLakeTable [Technical Preview] |
| GeoEnrichIP | PutClouderaORC | UpdateHive3Table |
| GeoEnrichIPRecord | PutCloudWatchMetric | UpdateRecord |
| GeohashRecord | PutCouchbaseKey | ValidateCsv |
| GetAsanaObject | PutDatabaseRecord1 | ValidateJson |
| GetAwsPollyJobStatus | PutDistributedMapCache | ValidateRecord |
| GetAwsTextractJobStatus | PutDropbox | ValidateXml |
| GetAwsTranscribeJobStatus | PutDynamoDB | VerifyContentMAC |
| GetAwsTranslateJobStatus | PutDynamoDBRecord | VerifyContentPGP |
| GetAzureEventHub | PutElasticsearchJson | Wait |
| GetAzureQueueStorage_v12 | PutElasticsearchRecord1 | YandexTranslate |
| GetCouchbaseKey1 | PutEmail |
Footnotes
- 1 – indicates a memory-intensive processor
- 2 – indicates a CPU-intensive processor
