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.
| AttributesToCSV | GetAwsTranscribeJobStatus | PutDropbox |
| AttributesToJSON | GetAwsTranslateJobStatus | PutDynamoDB |
| CalculateParquetOffsets | GetAzureEventHub | PutDynamoDBRecord |
| CalculateParquetRowGroupOffsets | GetAzureQueueStorage_v12 | PutElasticsearchJson |
| CalculateRecordStats | GetBoxFileCollaborators | PutElasticsearchRecord |
| CaptureChangeDebeziumDB2 | GetBoxGroupMembers | PutEmail |
| CaptureChangeDebeziumMongoDB | GetCouchbaseKey | PutFile |
| CaptureChangeDebeziumMySQL | GetElasticsearch | PutFTP |
| CaptureChangeDebeziumOracle | GetFile | PutGCSObject |
| CaptureChangeDebeziumPostgreSQL | GetFTP | PutGoogleDrive |
| CaptureChangeDebeziumSQLServer | GetGcpVisionAnnotateFilesOperationStatus | PutGridFS |
| CaptureChangeMySQL | GetGcpVisionAnnotateImagesOperationStatus | PutHBaseCell |
| ChunkDocument | GetHBase | PutHBaseJSON |
| CompressContent | GetHDFS | PutHBaseRecord |
| ConnectWebSocket | GetHDFSFileInfo | PutHDFS |
| ConsumeAMQP | GetHDFSSequenceFile | PutHive3QL |
| ConsumeAzureEventHub | GetHubSpot | PutHive3Streaming |
| ConsumeBoxEnterpriseEvents | GetJiraIssue | PutIceberg |
| ConsumeBoxEvents | GetMongoRecord | PutIcebergCDC |
| ConsumeElasticsearch | GetS3ObjectTags | PutJiraIssue |
| ConsumeGCPubSub | GetSFTP | PutKinesisFirehose |
| ConsumeGCPubSubLite | GetShopify | PutKinesisStream |
| ConsumeJMS | GetSNMP | PutKudu |
| ConsumeKafka_2_6 | GetSnowflakeIngestStatus | PutLambda |
| ConsumeKafka2CDP | GetSolr | PutMongoBulkOperations |
| ConsumeKafka2RecordCDP | GetSplunk | PutMongoRecord |
| ConsumeKafkaRecord_2_6 | GetSQS | PutORC |
| ConsumeKinesis | GetWorkdayReport | PutParquet |
| ConsumeKinesisStream | GetZendesk | PutPinecone |
| ConsumeMQTT | HandleHttpRequest | PutPLC |
| ConsumeMQTTIIoT | HandleHttpResponse | PutRecord |
| ConsumePLC | IdentifyMimeType | PutRedisHashRecord |
| ConsumeSlack | InvokeAWSGatewayApi | PutS3Object |
| ConsumeTwitter | InvokeGRPC | PutSalesforceObject |
| ConsumeWindowsEventLog | InvokeHTTP | PutSFTP |
| ControlRate | InvokeScriptedProcessor | PutSmbFile |
| ConvertAvroToJSON | JoinEnrichment | PutSnowflakeInternalStage |
| 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 |
| EvaluateJsonPath | ListSFTP | SawmillTransformJSON |
| EvaluateXPath | ListSmb | SawmillTransformRecord |
| EvaluateXQuery | LogAttribute | ScanAccumulo |
| ExecuteGraphQuery | LogMessage | ScanAttribute |
| ExecuteGraphQueryRecord | LookupAttribute | ScanContent |
| ExecuteGroovyScript | LookupRecord | ScanHBase |
| ExecuteProcess | MergeContent | ScriptedFilterRecord |
| ExecuteScript | MergeRecord | ScriptedPartitionRecord |
| ExecuteSQL | ModifyCompression | ScriptedTransformRecord |
| ExecuteSQLRecord | MonitorActivity | ScriptedValidateRecord |
| ExecuteStateless | MoveAzureDataLakeStorage | SearchElasticsearch |
| ExecuteStreamCommand | MoveHDFS | SegmentContent |
| ExtractAvroMetadata | Notify | SelectClouderaHiveQL |
| ExtractGrok | PackageFlowFile | SelectHive3QL |
| ExtractHL7Attributes | PaginatedJsonQueryElasticsearch | SendTrapSNMP |
| ExtractImageMetadata | ParseCEF | SetSNMP |
| ExtractRecordSchema | ParseDocument | SignContentPGP |
| ExtractStructuredBoxFileMetadata | ParseEvtx | SplitAvro |
| ExtractText | ParseSyslog | SplitContent |
| FetchAzureBlobStorage_v12 | PartitionRecord | SplitJson |
| FetchAzureDataLakeStorage | PromptAzureOpenAI | SplitRecord |
| FetchBoxFile | PromptChatGPT | SplitText |
| FetchBoxFileInfo | PromptClaude | SplitXml |
| FetchBoxFileMetadataInstance | PromptOpenAI | StartAwsPollyJob |
| FetchBoxFileRepresentation | PublishAMQP | StartAwsTextractJob |
| FetchCDPObjectStore | PublishGCPubSub | StartAwsTranscribeJob |
| FetchDistributedMapCache | PublishGCPubSubLite | StartAwsTranslateJob |
| FetchDropbox | PublishJMS | StartGcpVisionAnnotateFilesOperation |
| FetchFile | PublishKafka_2_6 | StartGcpVisionAnnotateImagesOperation |
| FetchFTP | PublishKafka2CDP | StartSnowflakeIngest |
| FetchGCSObject | PublishKafka2RecordCDP | TagS3Object |
| FetchGoogleDrive | PublishKafkaRecord_2_6 | TailFile |
| FetchGridFS | PublishMQTT | TokenCount |
| FetchHBaseRow | PublishSlack | TransformXml |
| FetchHDFS | PutAccumuloRecord | TriggerClouderaHiveMetaStoreEvent |
| FetchParquet | PutAzureBlobStorage_v12 | TriggerHiveMetaStoreEvent |
| FetchPLC | PutAzureCosmosDBRecord | UnpackContent |
| FetchS3Object | PutAzureDataLakeStorage | UpdateAttribute |
| FetchSFTP | PutAzureEventHub | UpdateBoxFileMetadataInstance |
| FetchSmb | PutAzureQueueStorage_v12 | UpdateByQueryElasticsearch |
| FilterAttribute | PutBigQuery | UpdateClouderaHiveTable |
| FlattenJson | PutBoxFile | UpdateCounter |
| ForkEnrichment | PutCassandraQL | UpdateDatabaseTable |
| ForkRecord | PutCassandraRecord | UpdateDeltaLakeTable |
| GenerateFlowFile | PutCDPObjectStore | UpdateHive3Table |
| GenerateRecord | PutChroma | UpdateRecord |
| GenerateTableFetch | PutClouderaHiveQL | ValidateCsv |
| GeoEnrichIP | PutClouderaHiveStreaming | ValidateJson |
| GeoEnrichIPRecord | PutClouderaORC | ValidateRecord |
| GeohashRecord | PutCloudWatchMetric | ValidateXml |
| GetAsanaObject | PutCouchbaseKey | VerifyContentMAC |
| GetAwsPollyJobStatus | PutDatabaseRecord | VerifyContentPGP |
| GetAwsTextractJobStatus | PutDistributedMapCache | Wait |
| YandexTranslate |
