Supported NiFi processors

Learn about the NiFi processors supported by Cloudera that you can use with Cloudera Data Flow.

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 or incomplete test case coverage, declaration of non-production readiness by the community at large, and feature deviation from Cloudera best practices. Do not use these processors in your production environments.

NiFi 1.27

AttributesToCSV AttributesToJSON Base64EncodeContent CalculateParquetOffsets CalculateParquetRowGroupOffsets CalculateRecordStats CaptureChangeDebeziumDB2 CaptureChangeDebeziumMySQL CaptureChangeDebeziumOracle CaptureChangeDebeziumPostgreSQL CaptureChangeDebeziumSQLServer CaptureChangeMySQL CompressContent ConnectWebSocket ConsumeAMQP ConsumeAzureEventHub ConsumeElasticsearch ConsumeEWS ConsumeGCPubSub ConsumeGCPubSubLite ConsumeJMS ConsumeKafka_1_0 ConsumeKafka_2_0 ConsumeKafka_2_6 ConsumeKafka2CDP ConsumeKafka2RecordCDP ConsumeKafkaRecord_1_0 ConsumeKafkaRecord_2_0 ConsumeKafkaRecord_2_6 ConsumeKinesisStream ConsumeMQTT ConsumePulsar ConsumePulsarRecord ConsumeTwitter ConsumeWindowsEventLog ControlRate ConvertAvroSchema ConvertAvroToJSON ConvertAvroToORC ConvertAvroToParquet ConvertCharacterSet ConvertCSVToAvro ConvertJSONToAvro ConvertJSONToSQL ConvertProtobuf ConvertRecord CreateHadoopSequenceFile CryptographicHashAttribute CryptographicHashContent DecryptContent DecryptContentAge DecryptContentCompatibility DecryptContentPGP DeduplicateRecord DeleteAzureBlobStorage DeleteAzureBlobStorage_v12 DeleteAzureDataLakeStorage DeleteByQueryElasticsearch DeleteCDPObjectStore DeleteDynamoDB DeleteGCSObject DeleteGridFS DeleteHBaseCells DeleteHBaseRow DeleteHDFS DeleteS3Object DeleteSFTP DeleteSQS DetectDuplicate DistributeLoad DuplicateFlowFile EncodeContent EncryptContent EncryptContentAge EncryptContentPGP EnforceOrder EvaluateJsonPath EvaluateXPath EvaluateXQuery ExecuteGroovyScript ExecuteInfluxDBQuery ExecuteProcess ExecuteScript ExecuteSQL ExecuteSQLRecord ExecuteStateless ExecuteStreamCommand ExtractAvroMetadata ExtractGrok ExtractHL7Attributes ExtractImageMetadata ExtractRecordSchema ExtractText FetchAzureBlobStorage FetchAzureBlobStorage_v12 FetchAzureDataLakeStorage FetchBoxFile FetchCDPObjectStore FetchDistributedMapCache FetchDropbox FetchElasticsearchHttp FetchFile FetchFTP FetchGCSObject FetchGoogleDrive FetchGridFS FetchHBaseRow FetchHDFS FetchParquet FetchS3Object FetchSFTP FetchSmb FilterAttribute FlattenJson ForkEnrichment ForkRecord GenerateFlowFile GenerateRecord GenerateTableFetch GeoEnrichIP GeoEnrichIPRecord GeohashRecord GetAsanaObject GetAwsPollyJobStatus GetAwsTextractJobStatus GetAwsTranscribeJobStatus GetAwsTranslateJobStatus GetAzureEventHub GetAzureQueueStorage GetAzureQueueStorage_v12 GetCouchbaseKey GetElasticsearch GetFile GetFTP GetGcpVisionAnnotateFilesOperationStatus GetGcpVisionAnnotateImagesOperationStatus GetHBase GetHDFS GetHDFSFileInfo GetHDFSSequenceFile GetHTMLElement GetHTTP GetHubSpot GetIgniteCache GetJiraIssue GetJMSQueue GetJMSTopic GetMongoRecord GetSFTP GetShopify GetSNMP GetSnowflakeIngestStatus GetSolr GetSplunk GetSQS GetTCP GetTwitter GetWorkdayReport GetZendesk HandleHttpRequest HandleHttpResponse HashAttribute HashContent IdentifyMimeType InvokeAWSGatewayApi InvokeGRPC InvokeGRPC InvokeHTTP InvokeScriptedProcessor JoinEnrichment JoltTransformJSON JoltTransformRecord JSLTTransformJSON JsonQueryElasticsearch ListAzureBlobStorage ListAzureBlobStorage_v12 ListAzureDataLakeStorage ListBoxFile ListCDPObjectStore ListDatabaseTables ListDropbox ListenBeats ListenFTP ListenGRPC ListenGRPC ListenHTTP ListenNetFlow ListenOTLP ListenRELP ListenSyslog ListenTCP ListenTCPRecord ListenTrapSNMP ListenUDP

ListenUDPRecord ListenWebSocket ListFile ListFTP ListGCSBucket ListGoogleDrive ListHDFS ListS3 ListSFTP ListSmb LogAttribute LogMessage LookupAttribute LookupRecord MergeContent MergeRecord ModifyCompression ModifyHTMLElement MonitorActivity MoveAzureDataLakeStorage MoveHDFS Notify PackageFlowFile PaginatedJsonQueryElasticsearch ParseCEF ParseEvtx ParseSyslog PartitionRecord PostHTTP PublishAMQP PublishGCPubSub PublishGCPubSubLite PublishJMS PublishKafka_1_0 PublishKafka_2_0 PublishKafka_2_6 PublishKafka2CDP PublishKafka2RecordCDP PublishKafkaRecord_1_0 PublishKafkaRecord_2_0 PublishKafkaRecord_2_6 PublishMQTT PublishPulsar PublishPulsarRecord PublishSlack PutAccumuloRecord PutAzureBlobStorage PutAzureBlobStorage_v12 PutAzureCosmosDBRecord PutAzureDataLakeStorage PutAzureEventHub PutAzureQueueStorage PutAzureQueueStorage_v12 PutBigQuery PutBigQueryBatch PutBigQueryStreaming PutBoxFile PutCassandraQL PutCassandraRecord PutCDPObjectStore PutClouderaHiveQL PutClouderaHiveStreaming PutClouderaORC PutCloudWatchMetric PutCouchbaseKey PutDatabaseRecord PutDistributedMapCache PutDropbox PutDynamoDB PutDynamoDBRecord PutElasticsearchHttp PutElasticsearchHttpRecord PutElasticsearchJson PutElasticsearchRecord PutEmail PutFile PutFTP PutGCSObject PutGoogleDrive PutGridFS PutHBaseCell PutHBaseJSON PutHBaseRecord PutHDFS PutHive3QL PutHive3Streaming PutHiveQL PutHiveStreaming PutHTMLElement PutIceberg PutIcebergCDC1 PutInfluxDB PutJiraIssue PutJMS PutKinesisFirehose PutKinesisStream PutKudu PutLambda PutMongoRecord PutORC PutParquet PutRecord PutRedisHashRecord1 PutRiemann PutS3Object PutSalesforceObject PutSFTP PutSmbFile PutSnowflakeInternalStage PutSNS PutSolrContentStream PutSolrRecord PutSplunk PutSplunkHTTP PutSQL PutSQS PutSyslog PutTCP PutUDP PutWebSocket PutZendeskTicket QueryAirtableTable QueryCassandra QueryDatabaseTable QueryDatabaseTableRecord QueryElasticsearchHttp QueryRecord QuerySalesforceObject QuerySolr QuerySplunkIndexingStatus QueryWhois RemoveRecordField ReplaceText ReplaceTextWithMapping ResizeImage RetryFlowFile RouteHL7 RouteOnAttribute RouteOnContent RouteText SampleRecord ScanAccumulo ScanAttribute ScanContent ScanHBase ScriptedFilterRecord ScriptedPartitionRecord ScriptedTransformRecord ScriptedValidateRecord ScrollElasticsearchHttp SearchElasticsearch SegmentContent SelectClouderaHiveQL SelectHive3QL SelectHiveQL SendTrapSNMP SetSNMP SignContentPGP SplitAvro SplitContent SplitJson SplitRecord SplitText SplitXml StartAwsPollyJob StartAwsTextractJob StartAwsTranscribeJob StartAwsTranslateJob StartGcpVisionAnnotateFilesOperation StartGcpVisionAnnotateImagesOperation StartSnowflakeIngest TagS3Object TailFile TransformXml TriggerClouderaHiveMetaStoreEvent TriggerHiveMetaStoreEvent UnpackContent UpdateAttribute UpdateByQueryElasticsearch UpdateClouderaHiveTable UpdateCounter UpdateDatabaseTable UpdateDeltaLakeTable1 UpdateHive3Table UpdateHiveTable UpdateRecord ValidateCsv ValidateJson ValidateRecord ValidateXml VerifyContentMAC VerifyContentPGP Wait YandexTranslate

NiFi 2.3.0

AttributesToCSV AttributesToJSON CalculateParquetOffsets CalculateParquetRowGroupOffsets CalculateRecordStats CaptureChangeDebeziumDB21 CaptureChangeDebeziumMySQL1 CaptureChangeDebeziumOracle1 CaptureChangeDebeziumPostgreSQL1 CaptureChangeDebeziumSQLServer1 CaptureChangeMySQL ChunkDocument1 CompressContent ConnectWebSocket ConsumeAMQP ConsumeAzureEventHub ConsumeElasticsearch ConsumeGCPubSub ConsumeGCPubSubLite ConsumeJMS ConsumeKafka_2_6 ConsumeKafka2CDP ConsumeKafka2RecordCDP ConsumeKafkaRecord_2_6 ConsumeKinesisStream ConsumeMQTT ConsumePLC1 ConsumeSlack ConsumeTwitter ConsumeWindowsEventLog ControlRate ConvertAvroToJSON ConvertAvroToParquet ConvertCharacterSet ConvertJSONToSQL ConvertProtobuf ConvertRecord CopyAzureBlobStorage_v12 CreateHadoopSequenceFile CryptographicHashContent DecryptContent DecryptContentAge DecryptContentCompatibility DecryptContentPGP DeduplicateRecord DeleteAzureBlobStorage_v12 DeleteAzureDataLakeStorage DeleteByQueryElasticsearch DeleteCDPObjectStore DeleteDynamoDB DeleteGCSObject DeleteGridFS DeleteHBaseCells DeleteHBaseRow DeleteHDFS DeleteS3Object DeleteSQS DetectDuplicate DistributeLoad DuplicateFlowFile EncodeContent EncryptContentAge EncryptContentPGP EnforceOrder EvaluateJsonPath EvaluateXPath EvaluateXQuery ExecuteGroovyScript ExecuteProcess ExecuteScript ExecuteSQL ExecuteSQLRecord ExecuteStateless ExecuteStreamCommand ExtractAvroMetadata ExtractGrok ExtractHL7Attributes ExtractImageMetadata ExtractRecordSchema ExtractText FetchAzureBlobStorage_v12 FetchAzureDataLakeStorage FetchBoxFile FetchCDPObjectStore FetchDistributedMapCache FetchDropbox FetchFile FetchFTP FetchGCSObject FetchGoogleDrive FetchGridFS FetchHBaseRow FetchHDFS FetchParquet FetchPLC1 FetchS3Object FetchSFTP FetchSmb FilterAttribute FlattenJson ForkEnrichment ForkRecord GenerateFlowFile GenerateRecord GenerateTableFetch GeoEnrichIP GeoEnrichIPRecord GeohashRecord GetAsanaObject GetAwsPollyJobStatus GetAwsTextractJobStatus GetAwsTranscribeJobStatus GetAwsTranslateJobStatus GetAzureEventHub GetAzureQueueStorage_v12 GetCouchbaseKey GetElasticsearch GetFile GetFTP GetGcpVisionAnnotateFilesOperationStatus GetGcpVisionAnnotateImagesOperationStatus GetHBase GetHDFS GetHDFSFileInfo GetHDFSSequenceFile GetHubSpot GetJiraIssue GetMongoRecord GetSFTP GetShopify GetSNMP GetSnowflakeIngestStatus GetSolr GetSplunk GetSQS GetTCP GetWorkdayReport GetZendesk HandleHttpRequest HandleHttpResponse IdentifyMimeType InvokeAWSGatewayApi InvokeGRPC InvokeHTTP InvokeScriptedProcessor JoinEnrichment JoltTransformJSON JoltTransformRecord JSLTTransformJSON JsonQueryElasticsearch ListAzureBlobStorage_v12 ListAzureDataLakeStorage ListBoxFile ListCDPObjectStore ListDatabaseTables ListDropbox ListenBeats ListenFTP ListenGRPC ListenHTTP ListenNetFlow ListenOTLP ListenRELP ListenSlack ListenSyslog ListenTCP ListenTCPRecord ListenTrapSNMP ListenUDP ListenUDPRecord ListenWebSocket ListFile ListFTP ListGCSBucket ListGoogleDrive

ListHDFS ListS3 ListSFTP ListSmb LogAttribute LogMessage LookupAttribute LookupRecord MergeContent MergeRecord ModifyCompression MonitorActivity MoveAzureDataLakeStorage MoveHDFS Notify PackageFlowFile PaginatedJsonQueryElasticsearch ParseCEF ParseDocument1 ParseEvtx ParseSyslog PartitionRecord PromptChatGPT1 PublishAMQP PublishGCPubSub PublishGCPubSubLite PublishJMS PublishKafka_2_6 PublishKafka2CDP PublishKafka2RecordCDP PublishKafkaRecord_2_6 PublishMQTT PublishSlack PutAccumuloRecord PutAzureBlobStorage_v12 PutAzureCosmosDBRecord PutAzureDataLakeStorage PutAzureEventHub PutAzureQueueStorage_v12 PutBigQuery PutBoxFile PutCassandraQL PutCassandraRecord PutCDPObjectStore PutChroma1 PutClouderaHiveQL PutClouderaHiveStreaming PutClouderaORC PutCloudWatchMetric PutCouchbaseKey PutDatabaseRecord PutDistributedMapCache PutDropbox PutDynamoDB PutDynamoDBRecord PutElasticsearchJson PutElasticsearchRecord PutEmail PutFile PutFTP PutGCSObject PutGoogleDrive PutGridFS PutHBaseCell PutHBaseJSON PutHBaseRecord PutHDFS PutHive3QL PutHive3Streaming PutIceberg PutIcebergCDC1 PutJiraIssue PutKinesisFirehose PutKinesisStream PutKudu PutLambda PutMongoBulkOperations PutMongoRecord PutORC PutParquet PutPinecone1 PutPLC1 PutRecord PutRedisHashRecord1 PutS3Object PutSalesforceObject PutSFTP PutSmbFile PutSnowflakeInternalStage PutSNS PutSolrContentStream PutSolrRecord PutSplunk PutSplunkHTTP PutSQL PutSQS PutSyslog PutTCP PutUDP PutWebSocket PutZendeskTicket QueryAirtableTable QueryCassandra QueryChroma1 QueryDatabaseTable QueryDatabaseTableRecord QueryPinecone1 QueryRecord QuerySalesforceObject QuerySolr QuerySplunkIndexingStatus RemoveRecordField RenameRecordField ReplaceText ReplaceTextWithMapping ResizeImage RetryFlowFile RouteHL7 RouteOnAttribute RouteOnContent RouteText SampleRecord SawmillTransformJSON SawmillTransformRecord ScanAccumulo ScanAttribute ScanContent ScanHBase ScriptedFilterRecord ScriptedPartitionRecord ScriptedTransformRecord ScriptedValidateRecord SearchElasticsearch SegmentContent SelectClouderaHiveQL SelectHive3QL SendTrapSNMP SetSNMP SignContentPGP SplitAvro SplitContent SplitJson SplitRecord SplitText SplitXml StartAwsPollyJob StartAwsTextractJob StartAwsTranscribeJob StartAwsTranslateJob StartGcpVisionAnnotateFilesOperation StartGcpVisionAnnotateImagesOperation StartSnowflakeIngest TagS3Object TailFile TransformXml TriggerClouderaHiveMetaStoreEvent TriggerHiveMetaStoreEvent UnpackContent UpdateAttribute UpdateByQueryElasticsearch UpdateClouderaHiveTable UpdateCounter UpdateDatabaseTable UpdateDeltaLakeTable1 UpdateHive3Table UpdateRecord ValidateCsv ValidateJson ValidateRecord ValidateXml VerifyContentMAC VerifyContentPGP Wait YandexTranslate

Python processors [Technical Preview]

Bedrock ChunkData ChunkDocument EmbedData InsertToMilvus LexicalQueryMilvus ParseDocument PartitionCsv PartitionDocx PartitionHtml PartitionPdf PartitionText PromptAzureOpenAI PromptChatGPT PromptClaude PromptOpenAI PutChroma PutOpenSearchVector PutPinecone PutQdrant QueryChroma QueryOpenSearchVector QueryPinecone QueryQdrant VectorQueryMilvus