Supported NiFi processors
Review the list of Apache NiFi processors supported in Cloudera Flow Management 4.13.0.
Apache NiFi provides a wide range of processors for building dataflows. Cloudera Flow Management 4.13.0 is based on Apache NiFi 2.6.0 and includes most of these processors, but not all are supported by Cloudera.
Some processors available in Apache NiFi are developed and maintained by the community and are not supported in Cloudera. These processors may be excluded due to factors such as limited testing, insufficient reliability, lack of production readiness, or misalignment with Cloudera best practices.
To ensure stability, performance, and full support coverage, use only processors that are officially supported by Cloudera in production environments.
| AttributesToCSV | GetAwsTranscribeJobStatus | PutDynamoDB |
| AttributesToJSON | GetAwsTranslateJobStatus | PutDynamoDBRecord |
| CalculateParquetOffsets | GetAzureEventHub | PutElasticsearchJson |
| CalculateParquetRowGroupOffsets | GetAzureQueueStorage_v12 | PutElasticsearchRecord |
| CalculateRecordStats | GetBoxFileCollaborators | PutEmail |
| CaptureChangeDebeziumDB2 | GetBoxGroupMembers | PutFile |
| CaptureChangeDebeziumMongoDB | GetCouchbaseKey | PutFTP |
| CaptureChangeDebeziumMySQL | GetElasticsearch | PutGCSObject |
| CaptureChangeDebeziumOracle | GetFile | PutGoogleDrive |
| CaptureChangeDebeziumPostgreSQL | GetFTP | PutGridFS |
| CaptureChangeDebeziumSQLServer | GetGcpVisionAnnotateFilesOperationStatus | PutHBaseCell |
| CaptureChangeMySQL | GetGcpVisionAnnotateImagesOperationStatus | PutHBaseJSON |
| ChunkDocument | GetHBase | PutHBaseRecord |
| CompressContent | GetHDFS | PutHDFS |
| ConnectWebSocket | GetHDFSFileInfo | PutHive3QL |
| ConsumeAMQP | GetHDFSSequenceFile | PutHive3Streaming |
| ConsumeAzureEventHub | GetHubSpot | PutIceberg |
| ConsumeBoxEnterpriseEvents | GetJiraIssue | PutIcebergCDC |
| ConsumeBoxEvents | GetMongoRecord | PutJiraIssue |
| ConsumeElasticsearch | GetS3ObjectTags | PutKinesisFirehose |
| ConsumeGCPubSub | GetSFTP | PutKinesisStream |
| ConsumeGCPubSubLite | GetShopify | PutKudu |
| ConsumeJMS | GetSNMP | PutLambda |
| ConsumeKafka_2_6 | GetSnowflakeIngestStatus | PutMongoBulkOperations |
| ConsumeKafka2CDP | GetSolr | PutMongoRecord |
| ConsumeKafka2RecordCDP | GetSplunk | PutORC |
| ConsumeKafkaRecord_2_6 | GetSQS | PutParquet |
| ConsumeKinesis | GetWorkdayReport | PutPinecone |
| ConsumeKinesisStream | GetZendesk | PutPLC |
| ConsumeMQTT | HandleHttpRequest | PutRecord |
| ConsumeMQTTIIoT | HandleHttpResponse | PutRedisHashRecord |
| ConsumePLC | IdentifyMimeType | PutS3Object |
| ConsumeSlack | InvokeAWSGatewayApi | PutSalesforceObject |
| ConsumeTwitter | InvokeGRPC | PutSFTP |
| ConsumeWindowsEventLog | InvokeHTTP | PutSmbFile |
| ControlRate | InvokeScriptedProcessor | PutSnowflakeInternalStage |
| ConvertAvroToJSON | JoinEnrichment | PutSnowflakeStreaming |
| ConvertAvroToParquet | JoltTransformJSON | PutSNS |
| ConvertCharacterSet | JoltTransformRecord | PutSolrContentStream |
| ConvertJSONToSQL | JSLTTransformJSON | PutSolrRecord |
| ConvertProtobuf | JsonQueryElasticsearch | PutSplunk |
| ConvertRecord | ListAzureBlobStorage_v12 | PutSplunkHTTP |
| CopyAzureBlobStorage_v12 | ListAzureDataLakeStorage | PutSQL |
| CountText | ListBoxFile | PutSQS |
| CreateBoxFileMetadataInstance | ListBoxFileInfo | PutSyslog |
| CreateBoxMetadataTemplate | ListBoxFileMetadataInstances | PutTCP |
| CreateHadoopSequenceFile | ListBoxFileMetadataTemplates | PutUDP |
| CryptographicHashContent | ListCDPObjectStore | PutWebSocket |
| DecryptContentAge | ListDatabaseTables | PutZendeskTicket |
| DecryptContentPGP | ListDropbox | QueryAirtableTable |
| DeduplicateRecord | ListenBeats | QueryCassandra |
| DeleteAzureBlobStorage_v12 | ListenFTP | QueryChroma |
| DeleteAzureDataLakeStorage | ListenGRPC | QueryDatabaseTable |
| DeleteBoxFileMetadataInstance | ListenHTTP | QueryDatabaseTableRecord |
| DeleteByQueryElasticsearch | ListenNetFlow | QueryPinecone |
| DeleteCDPObjectStore | ListenOTLP | QueryRecord |
| DeleteDynamoDB | ListenRELP | QuerySalesforceObject |
| DeleteGCSObject | ListenSlack | QuerySolr |
| DeleteGridFS | ListenSyslog | QuerySplunkIndexingStatus |
| DeleteHBaseCells | ListenTCP | QueryWhois |
| DeleteHBaseRow | ListenTCPRecord | RemoveRecordField |
| DeleteHDFS | ListenTrapSNMP | RenameRecordField |
| DeleteS3Object | ListenUDP | ReplaceText |
| DeleteSQS | ListenUDPRecord | ReplaceTextWithMapping |
| DetectDuplicate | ListenWebSocket | ResizeImage |
| DistributeLoad | ListFile | RetryFlowFile |
| DuplicateFlowFile | ListFTP | RouteHL7 |
| EncodeContent | ListGCSBucket | RouteOnAttribute |
| EncryptContentAge | ListGoogleDrive | RouteOnContent |
| EncryptContentPGP | ListHDFS | RouteText |
| EnforceOrder | ListS3 | SampleRecord |
| EnrichGraphRecord | ListSFTP | SawmillTransformJSON |
| EvaluateJsonPath | ListSmb | SawmillTransformRecord |
| EvaluateXPath | LogAttribute | ScanAccumulo |
| EvaluateXQuery | LogMessage | ScanAttribute |
| ExecuteGraphQuery | LookupAttribute | ScanContent |
| ExecuteGraphQueryRecord | LookupRecord | ScanHBase |
| ExecuteGroovyScript | MergeContent | ScriptedFilterRecord |
| ExecuteProcess | MergeRecord | ScriptedPartitionRecord |
| ExecuteScript | ModifyCompression | ScriptedTransformRecord |
| ExecuteSQL | MonitorActivity | ScriptedValidateRecord |
| ExecuteSQLRecord | MoveAzureDataLakeStorage | SearchElasticsearch |
| ExecuteStateless | MoveHDFS | SegmentContent |
| ExecuteStreamCommand | Notify | SelectClouderaHiveQL |
| ExtractAvroMetadata | PackageFlowFile | SelectHive3QL |
| ExtractGrok | PaginatedJsonQueryElasticsearch | SendTrapSNMP |
| ExtractHL7Attributes | ParseCEF | SetSNMP |
| ExtractImageMetadata | ParseDocument | SignContentPGP |
| ExtractRecordSchema | ParseEvtx | SplitAvro |
| ExtractStructuredBoxFileMetadata | ParseSyslog | SplitContent |
| ExtractText | PartitionRecord | SplitJson |
| FetchAzureBlobStorage_v12 | PromptAzureOpenAI | SplitRecord |
| FetchAzureDataLakeStorage | PromptChatGPT | SplitText |
| FetchBoxFile | PromptClaude | SplitXml |
| FetchBoxFileInfo | PromptOpenAI | StartAwsPollyJob |
| FetchBoxFileMetadataInstance | PublishAMQP | StartAwsTextractJob |
| FetchBoxFileRepresentation | PublishGCPubSub | StartAwsTranscribeJob |
| FetchCDPObjectStore | PublishGCPubSubLite | StartAwsTranslateJob |
| FetchDistributedMapCache | PublishJMS | StartGcpVisionAnnotateFilesOperation |
| FetchDropbox | PublishKafka_2_6 | StartGcpVisionAnnotateImagesOperation |
| FetchFile | PublishKafka2CDP | StartSnowflakeIngest |
| FetchFTP | PublishKafka2RecordCDP | TagS3Object |
| FetchGCSObject | PublishKafkaRecord_2_6 | TailFile |
| FetchGoogleDrive | PublishMQTT | TokenCount |
| FetchGridFS | PublishSlack | TransformXml |
| FetchHBaseRow | PutAccumuloRecord | TriggerClouderaHiveMetaStoreEvent |
| FetchHDFS | PutAzureBlobStorage_v12 | TriggerHiveMetaStoreEvent |
| FetchParquet | PutAzureCosmosDBRecord | UnpackContent |
| FetchPLC | PutAzureDataLakeStorage | UpdateAttribute |
| FetchS3Object | PutAzureEventHub | UpdateBoxFileMetadataInstance |
| FetchSFTP | PutAzureQueueStorage_v12 | UpdateByQueryElasticsearch |
| FetchSmb | PutBigQuery | UpdateClouderaHiveTable |
| FilterAttribute | PutBoxFile | UpdateCounter |
| FlattenJson | PutCassandraQL | UpdateDatabaseTable |
| ForkEnrichment | PutCassandraRecord | UpdateDeltaLakeTable |
| ForkRecord | PutCDPObjectStore | UpdateHive3Table |
| GenerateFlowFile | PutChroma | UpdateRecord |
| GenerateRecord | PutClouderaHiveQL | ValidateCsv |
| GenerateTableFetch | PutClouderaHiveStreaming | ValidateJson |
| GeoEnrichIP | PutClouderaORC | ValidateRecord |
| GeoEnrichIPRecord | PutCloudWatchMetric | ValidateXml |
| GeohashRecord | PutCouchbaseKey | VerifyContentMAC |
| GetAwsPollyJobStatus | PutDatabaseRecord | VerifyContentPGP |
| GetAwsTextractJobStatus | PutDistributedMapCache | Wait |
| PutDropbox | YandexTranslate |
