Supported NiFi processors
Review the list of Apache NiFi processors supported in Cloudera Flow Management 4.12.0.
Apache NiFi provides a wide range of processors for building dataflows. Cloudera Flow Management 4.12.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.
| AttributeRollingWindow | GetAwsTranslateJobStatus | PutClouderaORC |
| AttributesToCSV | GetAzureEventHub | PutCloudWatchMetric |
| AttributesToJSON | GetAzureQueueStorage_v12 | PutCouchbase |
| CalculateParquetOffsets | GetBoxFileCollaborators | PutDatabaseRecord |
| CalculateParquetRowGroupOffsets | GetBoxGroupMembers | PutDistributedMapCache |
| CalculateRecordStats | GetCouchbase | PutDropbox |
| CaptureChangeDebeziumDB2 | GetDynamoDB | PutDynamoDB |
| CaptureChangeDebeziumMongoDB | GetElasticsearch | PutDynamoDBRecord |
| CaptureChangeDebeziumMySQL | GetFile | PutElasticsearchJson |
| CaptureChangeDebeziumOracle | GetFileResource | PutElasticsearchRecord |
| CaptureChangeDebeziumPostgreSQL | GetFTP | PutEmail |
| CaptureChangeDebeziumSQLServer | GetGcpVisionAnnotateFilesOperationStatus | PutFile |
| CaptureChangeMySQL | GetGcpVisionAnnotateImagesOperationStatus | PutFTP |
| ChunkData | GetHBase | PutGCSObject |
| ChunkDocument | GetHDFS | PutGoogleDrive |
| CompressContent | GetHDFSEvents | PutGridFS |
| ConnectWebSocket | GetHDFSFileInfo | PutHBaseCell |
| ConsumeAMQP | GetHDFSSequenceFile | PutHBaseJSON |
| ConsumeAzureEventHub | GetHubSpot | PutHBaseRecord |
| ConsumeBoxEnterpriseEvents | GetJiraIssue | PutHDFS |
| ConsumeBoxEvents | GetMongo | PutIceberg |
| ConsumeElasticsearch | GetMongoRecord | PutIcebergCDC |
| ConsumeGCPubSub | GetS3ObjectMetadata | PutIoTDBRecord |
| ConsumeIMAP | GetS3ObjectTags | PutJiraIssue |
| ConsumeJMS | GetSFTP | PutKinesisFirehose |
| ConsumeKafka | GetShopify | PutKinesisStream |
| ConsumeKafka_2_6 | GetSlackReaction | PutKudu |
| ConsumeKafka2CDP | GetSmbFile | PutLambda |
| ConsumeKafka2RecordCDP | GetSNMP | PutMongo |
| ConsumeKafkaRecord_2_6 | GetSnowflakeIngestStatus | PutMongoBulkOperations |
| ConsumeKinesisStream | GetSolr | PutMongoRecord |
| ConsumeMQTT | GetSplunk | PutOpenSearchVector |
| ConsumeMQTTIIoT | GetSQS | PutParquet |
| ConsumePLC | GetTCP | PutPinecone |
| ConsumePOP3 | GetWorkdayReport | PutPLC |
| ConsumeSlack | GetZendesk | PutQdrant |
| ConsumeTwitter | HandleHttpRequest | PutRecord |
| ConsumeWindowsEventLog | HandleHttpResponse | PutRedisHashRecord |
| ControlRate | IdentifyMimeType | PutS3Object |
| ConvertAvroToParquet | InsertToMilvus | PutSalesforceObject |
| ConvertCharacterSet | InvokeGRPC | PutSFTP |
| ConvertProtobuf | InvokeHTTP | PutSmbFile |
| ConvertRecord | InvokeScriptedProcessor | PutSnowflakeInternalStage |
| CopyAzureBlobStorage_v12 | ISPEnrichIP | PutSNS |
| CopyS3Object | JoinEnrichment | PutSolrContentStream |
| CountText | JoltTransformJSON | PutSolrRecord |
| CreateBoxFileMetadataInstance | JoltTransformRecord | PutSplunk |
| CreateBoxMetadataTemplate | JSLTTransformJSON | PutSplunkHTTP |
| CreateHadoopSequenceFile | JsonQueryElasticsearch | PutSQL |
| CryptographicHashContent | LexicalQueryMilvus | PutSQS |
| DebugFlow | ListAzureBlobStorage_v12 | PutSyslog |
| DecryptContentAge | ListAzureDataLakeStorage | PutTCP |
| DecryptContentPGP | ListBoxFile | PutUDP |
| DeduplicateRecord | ListBoxFileInfo | PutWebSocket |
| DeleteAzureBlobStorage_v12 | ListBoxFileMetadataInstances | PutZendeskTicket |
| DeleteAzureDataLakeStorage | ListBoxFileMetadataTemplates | QueryAirtableTable |
| DeleteBoxFileMetadataInstance | ListCDPObjectStore | QueryAzureDataExplorer |
| DeleteByQueryElasticsearch | ListDatabaseTables | QueryCassandra |
| DeleteCDPObjectStore | ListDropbox | QueryChroma |
| DeleteDynamoDB | ListenBeats | QueryDatabaseTable |
| DeleteFile | ListenFTP | QueryDatabaseTableRecord |
| DeleteGCSObject | ListenGRPC | QueryIoTDBRecord |
| DeleteGridFS | ListenHTTP | QueryOpenSearchVector |
| DeleteHBaseCells | ListenNetFlow | QueryPinecone |
| DeleteHBaseRow | ListenOTLP | QueryQdrant |
| DeleteHDFS | ListenSlack | QueryRecord |
| DeleteMongo | ListenSyslog | QuerySalesforceObject |
| DeleteS3Object | ListenTCP | QuerySolr |
| DeleteSFTP | ListenTrapSNMP | QuerySplunkIndexingStatus |
| DeleteSQS | ListenUDP | RemoveRecordField |
| DetectDuplicate | ListenUDPRecord | RenameRecordField |
| DistributeLoad | ListenWebSocket | ReplaceText |
| DuplicateFlowFile | ListFile | ReplaceTextWithMapping |
| EmbedData | ListFTP | ResizeImage |
| EncodeContent | ListGCSBucket | RetryFlowFile |
| EncryptContentAge | ListGoogleDrive | RouteHL7 |
| EncryptContentPGP | ListHBaseRegions | RouteOnAttribute |
| EnforceOrder | ListHDFS | RouteOnContent |
| EvaluateJsonPath | ListS3 | RouteText |
| EvaluateXPath | ListSFTP | RunMongoAggregation |
| EvaluateXQuery | ListSmb | SampleRecord |
| ExecuteGraphQuery | LogAttribute | SawmillTransformJSON |
| ExecuteGraphQueryRecord | LogMessage | SawmillTransformRecord |
| ExecuteGroovyScript | LookupAttribute | ScanAccumulo |
| ExecuteProcess | LookupRecord | ScanAttribute |
| ExecuteScript | MergeContent | ScanContent |
| ExecuteSparkInteractive | MergeRecord | ScanHBase |
| ExecuteSQL | ModifyBytes | ScriptedFilterRecord |
| ExecuteSQLRecord | ModifyCompression | ScriptedPartitionRecord |
| ExecuteStreamCommand | MonitorActivity | ScriptedTransformRecord |
| ExtractAvroMetadata | MoveAzureDataLakeStorage | ScriptedValidateRecord |
| ExtractDocumentText | MoveHDFS | SearchElasticsearch |
| ExtractEmailAttachments | Notify | SegmentContent |
| ExtractEmailHeaders | PackageFlowFile | SelectClouderaHiveQL |
| ExtractGrok | PaginatedJsonQueryElasticsearch | SendTrapSNMP |
| ExtractHL7Attributes | ParseDocument | SetSNMP |
| ExtractImageMetadata | ParseEvtx | SignContentPGP |
| ExtractMediaMetadata | ParseNetflowv5 | SplitAvro |
| ExtractRecordSchema | ParseSyslog | SplitContent |
| ExtractStructuredBoxFileMetadata | ParseSyslog5424 | SplitExcel |
| ExtractText | PartitionCsv | SplitJson |
| FetchAzureBlobStorage_v12 | PartitionDocx | SplitPCAP |
| FetchAzureDataLakeStorage | PartitionHtml | SplitRecord |
| FetchBoxFile | PartitionPdf | SplitText |
| FetchBoxFileInfo | PartitionRecord | SplitXml |
| FetchBoxFileMetadataInstance | PartitionText | StartAwsPollyJob |
| FetchBoxFileRepresentation | PromptAzureOpenAI | StartAwsTextractJob |
| FetchCDPObjectStore | PromptBedrock | StartAwsTranscribeJob |
| FetchDistributedMapCache | PromptChatGPT | StartAwsTranslateJob |
| FetchDropbox | PromptClaude | StartGcpVisionAnnotateFilesOperation |
| FetchFile | PromptOpenAI | StartGcpVisionAnnotateImagesOperation |
| FetchFTP | PublishAMQP | StartSnowflakeIngest |
| FetchGCSObject | PublishGCPubSub | TagS3Object |
| FetchGoogleDrive | PublishJMS | TailFile |
| FetchGridFS | PublishKafka | TokenCount |
| FetchHBaseRow | PublishKafka_2_6 | TransformXml |
| FetchHDFS | PublishKafka2CDP | TriggerClouderaHiveMetaStoreEvent |
| FetchParquet | PublishKafka2RecordCDP | UnpackContent |
| FetchPLC | PublishKafkaRecord_2_6 | UpdateAttribute |
| FetchS3Object | PublishMQTT | UpdateBoxFileMetadataInstance |
| FetchSFTP | PublishSlack | UpdateByQueryElasticsearch |
| FetchSmb | PutAccumuloRecord | UpdateClouderaHiveTable |
| FilterAttribute | PutAzureBlobStorage_v12 | UpdateCounter |
| FlattenJson | PutAzureCosmosDBRecord | UpdateDatabaseTable |
| ForkEnrichment | PutAzureDataExplorer | UpdateDeltaLakeTable |
| ForkRecord | PutAzureDataLakeStorage | UpdateJiraIssue |
| GenerateFlowFile | PutAzureEventHub | UpdateRecord |
| GenerateRecord | PutAzureQueueStorage_v12 | ValidateCsv |
| GenerateTableFetch | PutBigQuery | ValidateJson |
| GeoEnrichIP | PutBoxFile | ValidateRecord |
| GeoEnrichIPRecord | PutCassandraQL | ValidateXml |
| GeohashRecord | PutCassandraRecord | VectorQueryMilvus |
| GetAsanaObject | PutCDPObjectStore | VerifyContentMAC |
| GetAwsPollyJobStatus | PutChroma | VerifyContentPGP |
| GetAwsTextractJobStatus | PutClouderaHiveQL | Wait |
| GetAwsTranscribeJobStatus | PutClouderaHiveStreaming |
