ListenGRPC

General

Developer

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

Controller Services
- AccumuloService 2.4.0.4.11.0.0-352
- ActiveMQJMSConnectionFactoryProvider 2.4.0.4.11.0.0-352
- ADLSCredentialsControllerService 2.4.0.4.11.0.0-352
- ADLSCredentialsControllerServiceLookup 2.4.0.4.11.0.0-352
- ADLSIDBrokerCloudCredentialsProviderControllerService 2.4.0.4.11.0.0-352
- AmazonGlueSchemaRegistry 2.4.0.4.11.0.0-352
- AmazonMSKConnectionService 2.4.0.4.11.0.0-352
- ApicurioSchemaRegistry 2.4.0.4.11.0.0-352
- AvroReader 2.4.0.4.11.0.0-352
- AvroRecordSetWriter 2.4.0.4.11.0.0-352
- AvroSchemaRegistry 2.4.0.4.11.0.0-352
- AWSCredentialsProviderControllerService 2.4.0.4.11.0.0-352
- AWSIDBrokerCloudCredentialsProviderControllerService 2.4.0.4.11.0.0-352
- AzureBlobIDBrokerCloudCredentialsProviderControllerService 2.4.0.4.11.0.0-352
- AzureBlobStorageFileResourceService 2.4.0.4.11.0.0-352
- AzureCosmosDBClientService 2.4.0.4.11.0.0-352
- AzureDataLakeStorageFileResourceService 2.4.0.4.11.0.0-352
- AzureEventHubRecordSink 2.4.0.4.11.0.0-352
- AzureServiceBusJMSConnectionFactoryProvider 2.4.0.4.11.0.0-352
- AzureStorageCredentialsControllerService_v12 2.4.0.4.11.0.0-352
- AzureStorageCredentialsControllerServiceLookup_v12 2.4.0.4.11.0.0-352
- CassandraDistributedMapCache 2.4.0.4.11.0.0-352
- CassandraSessionProvider 2.4.0.4.11.0.0-352
- CdpCredentialsProviderControllerService 2.4.0.4.11.0.0-352
- CdpOauth2AccessTokenProviderControllerService 2.4.0.4.11.0.0-352
- CEFReader 2.4.0.4.11.0.0-352
- CiscoEmblemSyslogMessageReader 2.4.0.4.11.0.0-352
- ClouderaAttributeSchemaReferenceReader 2.4.0.4.11.0.0-352
- ClouderaAttributeSchemaReferenceWriter 2.4.0.4.11.0.0-352
- ClouderaEncodedSchemaReferenceReader 2.4.0.4.11.0.0-352
- ClouderaEncodedSchemaReferenceWriter 2.4.0.4.11.0.0-352
- ClouderaHiveConnectionPool 2.4.0.4.11.0.0-352
- ClouderaHiveConnectionPoolLookup 2.4.0.4.11.0.0-352
- ClouderaSchemaRegistry 2.4.0.4.11.0.0-352
- CMLLookupService 2.4.0.4.11.0.0-352
- ConfluentEncodedSchemaReferenceReader 2.4.0.4.11.0.0-352
- ConfluentEncodedSchemaReferenceWriter 2.4.0.4.11.0.0-352
- ConfluentSchemaRegistry 2.4.0.4.11.0.0-352
- CouchbaseClusterService 2.4.0.4.11.0.0-352
- CouchbaseKeyValueLookupService 2.4.0.4.11.0.0-352
- CouchbaseMapCacheClient 2.4.0.4.11.0.0-352
- CouchbaseRecordLookupService 2.4.0.4.11.0.0-352
- CSVReader 2.4.0.4.11.0.0-352
- CSVRecordLookupService 2.4.0.4.11.0.0-352
- CSVRecordSetWriter 2.4.0.4.11.0.0-352
- DatabaseRecordLookupService 2.4.0.4.11.0.0-352
- DatabaseRecordSink 2.4.0.4.11.0.0-352
- DatabaseTableSchemaRegistry 2.4.0.4.11.0.0-352
- DBCPConnectionPool 2.4.0.4.11.0.0-352
- DBCPConnectionPoolLookup 2.4.0.4.11.0.0-352
- DeveloperBoxClientService 2.4.0.4.11.0.0-352
- DistributedMapCacheLookupService 2.4.0.4.11.0.0-352
- EBCDICRecordReader 2.4.0.4.11.0.0-352
- ElasticSearchClientServiceImpl 2.4.0.4.11.0.0-352
- ElasticSearchLookupService 2.4.0.4.11.0.0-352
- ElasticSearchStringLookupService 2.4.0.4.11.0.0-352
- EmailRecordSink 2.4.0.4.11.0.0-352
- EmbeddedHazelcastCacheManager 2.4.0.4.11.0.0-352
- ExcelReader 2.4.0.4.11.0.0-352
- ExternalHazelcastCacheManager 2.4.0.4.11.0.0-352
- FreeFormTextRecordSetWriter 2.4.0.4.11.0.0-352
- GCPCredentialsControllerService 2.4.0.4.11.0.0-352
- GCSFileResourceService 2.4.0.4.11.0.0-352
- GenericPLC4XConnectionPool 2.4.0.4.11.0.0-352
- GrokReader 2.4.0.4.11.0.0-352
- HadoopCatalogService 2.4.0.4.11.0.0-352
- HadoopDBCPConnectionPool 2.4.0.4.11.0.0-352
- HazelcastMapCacheClient 2.4.0.4.11.0.0-352
- HBase_2_ClientMapCacheService 2.4.0.4.11.0.0-352
- HBase_2_ClientService 2.4.0.4.11.0.0-352
- HBase_2_RecordLookupService 2.4.0.4.11.0.0-352
- HikariCPConnectionPool 2.4.0.4.11.0.0-352
- HiveCatalogService 2.4.0.4.11.0.0-352
- HttpRecordSink 2.4.0.4.11.0.0-352
- ImpalaConnectionPool 2.4.0.4.11.0.0-352
- IPFIXReader 2.4.0.4.11.0.0-352
- IPLookupService 2.4.0.4.11.0.0-352
- JASN1Reader 2.4.0.4.11.0.0-352
- JdbcCatalogService 2.4.0.4.11.0.0-352
- JettyWebSocketClient 2.4.0.4.11.0.0-352
- JettyWebSocketServer 2.4.0.4.11.0.0-352
- JiraRecordSink 2.4.0.4.11.0.0-352
- JMSConnectionFactoryProvider 2.4.0.4.11.0.0-352
- JndiJmsConnectionFactoryProvider 2.4.0.4.11.0.0-352
- JsonConfigBasedBoxClientService 2.4.0.4.11.0.0-352
- JsonPathReader 2.4.0.4.11.0.0-352
- JsonRecordSetWriter 2.4.0.4.11.0.0-352
- JsonTreeReader 2.4.0.4.11.0.0-352
- JWTBearerOAuth2AccessTokenProvider 2.4.0.4.11.0.0-352
- Kafka3ConnectionService 2.4.0.4.11.0.0-352
- Kafka3ConnectionService 2.4.0.4.11.0.0-352
- KafkaRecordSink_2_6 2.4.0.4.11.0.0-352
- KerberosKeytabUserService 2.4.0.4.11.0.0-352
- KerberosPasswordUserService 2.4.0.4.11.0.0-352
- KerberosTicketCacheUserService 2.4.0.4.11.0.0-352
- KuduLookupService 2.4.0.4.11.0.0-352
- LivySessionController 2.4.0.4.11.0.0-352
- LoggingRecordSink 2.4.0.4.11.0.0-352
- MapCacheClientService 2.4.0.4.11.0.0-352
- MapCacheServer 2.4.0.4.11.0.0-352
- MongoDBControllerService 2.4.0.4.11.0.0-352
- MongoDBLookupService 2.4.0.4.11.0.0-352
- Neo4JCypherClientService 2.4.0.4.11.0.0-352
- ParquetReader 2.4.0.4.11.0.0-352
- ParquetRecordSetWriter 2.4.0.4.11.0.0-352
- PEMEncodedSSLContextProvider 2.4.0.4.11.0.0-352
- PhoenixThickConnectionPool 2.4.0.4.11.0.0-352
- PhoenixThinConnectionPool 2.4.0.4.11.0.0-352
- PostgreSQLConnectionPool 2.4.0.4.11.0.0-352
- PropertiesFileLookupService 2.4.0.4.11.0.0-352
- ProtobufReader 2.4.0.4.11.0.0-352
- ProxyPLC4XConnectionPool 2.4.0.4.11.0.0-352
- RabbitMQJMSConnectionFactoryProvider 2.4.0.4.11.0.0-352
- ReaderLookup 2.4.0.4.11.0.0-352
- RecordSetWriterLookup 2.4.0.4.11.0.0-352
- RecordSinkServiceLookup 2.4.0.4.11.0.0-352
- RedisConnectionPoolService 2.4.0.4.11.0.0-352
- RedisDistributedMapCacheClientService 2.4.0.4.11.0.0-352
- RedshiftConnectionPool 2.4.0.4.11.0.0-352
- RESTCatalogService 2.4.0.4.11.0.0-352
- RestLookupService 2.4.0.4.11.0.0-352
- S3FileResourceService 2.4.0.4.11.0.0-352
- ScriptedLookupService 2.4.0.4.11.0.0-352
- ScriptedReader 2.4.0.4.11.0.0-352
- ScriptedRecordSetWriter 2.4.0.4.11.0.0-352
- ScriptedRecordSink 2.4.0.4.11.0.0-352
- SetCacheClientService 2.4.0.4.11.0.0-352
- SetCacheServer 2.4.0.4.11.0.0-352
- SimpleCsvFileLookupService 2.4.0.4.11.0.0-352
- SimpleDatabaseLookupService 2.4.0.4.11.0.0-352
- SimpleKeyValueLookupService 2.4.0.4.11.0.0-352
- SimpleRedisDistributedMapCacheClientService 2.4.0.4.11.0.0-352
- SimpleScriptedLookupService 2.4.0.4.11.0.0-352
- SiteToSiteReportingRecordSink 2.4.0.4.11.0.0-352
- SlackRecordSink 2.4.0.4.11.0.0-352
- SmbjClientProviderService 2.4.0.4.11.0.0-352
- SnowflakeComputingConnectionPool 2.4.0.4.11.0.0-352
- StandardAsanaClientProviderService 2.4.0.4.11.0.0-352
- StandardAzureCredentialsControllerService 2.4.0.4.11.0.0-352
- StandardDatabaseDialectService 2.4.0.4.11.0.0-352
- StandardDropboxCredentialService 2.4.0.4.11.0.0-352
- StandardFileResourceService 2.4.0.4.11.0.0-352
- StandardHashiCorpVaultClientService 2.4.0.4.11.0.0-352
- StandardHttpContextMap 2.4.0.4.11.0.0-352
- StandardJiraCredentialService 2.4.0.4.11.0.0-352
- StandardJsonSchemaRegistry 2.4.0.4.11.0.0-352
- StandardKustoIngestService 2.4.0.4.11.0.0-352
- StandardKustoQueryService 2.4.0.4.11.0.0-352
- StandardOauth2AccessTokenProvider 2.4.0.4.11.0.0-352
- StandardPGPPrivateKeyService 2.4.0.4.11.0.0-352
- StandardPGPPublicKeyService 2.4.0.4.11.0.0-352
- StandardPLC4XConnectionPool 2.4.0.4.11.0.0-352
- StandardPrivateKeyService 2.4.0.4.11.0.0-352
- StandardProxyConfigurationService 2.4.0.4.11.0.0-352
- StandardRestrictedSSLContextService 2.4.0.4.11.0.0-352
- StandardS3EncryptionService 2.4.0.4.11.0.0-352
- StandardSnowflakeIngestManagerProviderService 2.4.0.4.11.0.0-352
- StandardSSLContextService 2.4.0.4.11.0.0-352
- StandardWebClientServiceProvider 2.4.0.4.11.0.0-352
- Syslog5424Reader 2.4.0.4.11.0.0-352
- SyslogReader 2.4.0.4.11.0.0-352
- TinkerpopClientService 2.4.0.4.11.0.0-352
- UDPEventRecordSink 2.4.0.4.11.0.0-352
- VolatileSchemaCache 2.4.0.4.11.0.0-352
- WindowsEventLogReader 2.4.0.4.11.0.0-352
- XMLFileLookupService 2.4.0.4.11.0.0-352
- XMLReader 2.4.0.4.11.0.0-352
- XMLRecordSetWriter 2.4.0.4.11.0.0-352
- YamlTreeReader 2.4.0.4.11.0.0-352
- ZendeskRecordSink 2.4.0.4.11.0.0-352

Reporting Tasks
- AzureLogAnalyticsProvenanceReportingTask 2.4.0.4.11.0.0-352
- AzureLogAnalyticsReportingTask 2.4.0.4.11.0.0-352
- ControllerStatusReportingTask 2.4.0.4.11.0.0-352
- MonitorDiskUsage 2.4.0.4.11.0.0-352
- MonitorMemory 2.4.0.4.11.0.0-352
- QueryNiFiReportingTask 2.4.0.4.11.0.0-352
- ReportLineageToAtlas 2.4.0.4.11.0.0-352
- ScriptedReportingTask 2.4.0.4.11.0.0-352
- SiteToSiteBulletinReportingTask 2.4.0.4.11.0.0-352
- SiteToSiteMetricsReportingTask 2.4.0.4.11.0.0-352
- SiteToSiteProvenanceReportingTask 2.4.0.4.11.0.0-352
- SiteToSiteStatusReportingTask 2.4.0.4.11.0.0-352

Parameter Providers
- AwsSecretsManagerParameterProvider 2.4.0.4.11.0.0-352
- AzureKeyVaultSecretsParameterProvider 2.4.0.4.11.0.0-352
- CyberArkConjurParameterProvider 2.4.0.4.11.0.0-352
- DatabaseParameterProvider 2.4.0.4.11.0.0-352
- EnvironmentVariableParameterProvider 2.4.0.4.11.0.0-352
- GcpSecretManagerParameterProvider 2.4.0.4.11.0.0-352
- HashiCorpVaultParameterProvider 2.4.0.4.11.0.0-352
- KubernetesSecretParameterProvider 2.4.0.4.11.0.0-352
- OnePasswordParameterProvider 2.4.0.4.11.0.0-352

Flow Analysis Rules
- DisallowComponentType 2.4.0.4.11.0.0-352
- DisallowConsecutiveConnectionsWithRoundRobinLB 2.4.0.4.11.0.0-352
- DisallowDeadEnd 2.4.0.4.11.0.0-352
- DisallowDeprecatedProcessor 2.4.0.4.11.0.0-352
- DisallowExtractTextForFullContent 2.4.0.4.11.0.0-352
- RecommendRecordProcessor 2.4.0.4.11.0.0-352
- RequireHandleHttpResponseAfterHandleHttpRequest 2.4.0.4.11.0.0-352
- RequireMergeBeforePutIceberg 2.4.0.4.11.0.0-352
- RequireServerSSLContextService 2.4.0.4.11.0.0-352
- RestrictBackpressureSettings 2.4.0.4.11.0.0-352
- RestrictComponentNaming 2.4.0.4.11.0.0-352
- RestrictConcurrentTasksVsThreadPoolSizeInProcessors 2.4.0.4.11.0.0-352
- RestrictFlowFileExpiration 2.4.0.4.11.0.0-352
- RestrictProcessorConcurrency 2.4.0.4.11.0.0-352
- RestrictSchedulingForListProcessors 2.4.0.4.11.0.0-352
- RestrictThreadPoolSize 2.4.0.4.11.0.0-352
- RestrictYieldDurationForConsumeKafkaProcessors 2.4.0.4.11.0.0-352

ListenGRPC 2.4.0.4.11.0.0-352

Bundle: com.cloudera | nifi-cdf-grpc-nar
Description: Starts a gRPC server and listens on the given port to transform the incoming messages into FlowFiles. The message format can be a pre-defined standard FlowFile data structure (attributes and content) provided by NiFi or user defined message types and services can also be used. gRPC isn't intended to carry large payloads, so this processor should be used only when the message sizes are on the order of megabytes. The default maximum message size is 4MB.
Tags: grpc, ingest, listen, rpc
Input Requirement: FORBIDDEN
Supports Sensitive Dynamic Properties: false

Properties

Authorized DN Pattern
A Regular Expression to apply against the Distinguished Name of incoming connections. If the Pattern does not match the DN, the connection will be refused. The property will only be used if client certificate authentication (Mutual TLS) has been configured on SSL Context Service, otherwise it will be ignored.
Display Name

Authorized DN Pattern

Description

A Regular Expression to apply against the Distinguished Name of incoming connections. If the Pattern does not match the DN, the connection will be refused. The property will only be used if client certificate authentication (Mutual TLS) has been configured on SSL Context Service, otherwise it will be ignored.

API Name

Authorized DN Pattern

Default Value

.*

Expression Language Scope

Not Supported

Sensitive

false

Required

false

Dependencies
- Use TLS is set to any of [true]
Flow Control Window
The initial HTTP/2 flow control window for both new streams and overall connection. Flow-control schemes ensure that streams on the same connection do not destructively interfere with each other. The default is 1MB.

Display Name

Flow Control Window

Description

The initial HTTP/2 flow control window for both new streams and overall connection. Flow-control schemes ensure that streams on the same connection do not destructively interfere with each other. The default is 1MB.

API Name

Flow Control Window

Default Value

1MB

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Local gRPC Service Port
The local port that the gRPC service will listen on.

Display Name

Local gRPC Service Port

Description

The local port that the gRPC service will listen on.

API Name

Local gRPC service port

Expression Language Scope

Not Supported

Sensitive

false

Required

true
Maximum Message Size
The maximum size of FlowFiles that this processor will allow to be received. The default is 4MB. If FlowFiles exceed this size, you should consider using another transport mechanism as gRPC isn't designed for heavy payloads.

Display Name

Maximum Message Size

Description

The maximum size of FlowFiles that this processor will allow to be received. The default is 4MB. If FlowFiles exceed this size, you should consider using another transport mechanism as gRPC isn't designed for heavy payloads.

API Name

Max Message Size

Default Value

4MB

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Output Field
Field of the request message to output as the FlowFile content (e.g. customer.name). If not specified, the whole request message will be converted to JSON and will be set in the FlowFile content. If empty string specified, no FlowFile content will be set. The latter can be used when message fields are extracted to FlowFile attributes instead of content (see dynamic properties).
Display Name

Output Field

Description

Field of the request message to output as the FlowFile content (e.g. customer.name). If not specified, the whole request message will be converted to JSON and will be set in the FlowFile content. If empty string specified, no FlowFile content will be set. The latter can be used when message fields are extracted to FlowFile attributes instead of content (see dynamic properties).

API Name

output-field

Expression Language Scope

Environment variables defined at JVM level and system properties

Sensitive

false

Required

false

Dependencies
- Service Type is set to any of [custom-ingest-service]
Proto Directory
Directory containing Protocol Buffers message and service definition (.proto) file(s).
Display Name

Proto Directory

Description

Directory containing Protocol Buffers message and service definition (.proto) file(s).

API Name

proto-directory

Expression Language Scope

Environment variables defined at JVM level and system properties

Sensitive

false

Required

true

Dependencies
- Service Type is set to any of [custom-ingest-service]
Service Type
Pre-defined FlowFile ingest service or user defined custom services. In case of 'Custom Ingest Service', multiple services with multiple methods can be used. Each method will be handled as a data ingestion procedure and the request object will be converted to FlowFile content and/or FlowFile attributes. The response object will be null.
Display Name

Service Type

Description

Pre-defined FlowFile ingest service or user defined custom services. In case of 'Custom Ingest Service', multiple services with multiple methods can be used. Each method will be handled as a data ingestion procedure and the request object will be converted to FlowFile content and/or FlowFile attributes. The response object will be null.

API Name

service-type

Default Value

flowfile-ingest-service

Allowable Values
- FlowFile Ingest Service
- Custom Ingest Service
Expression Language Scope

Not Supported

Sensitive

false

Required

true
SSL Context Service
The SSL Context Service used to provide server certificate information for TLS (https) connections. Keystore must be configured on the service. If truststore is also configured, it will turn on and require client certificate authentication (Mutual TLS).
Display Name

SSL Context Service

Description

The SSL Context Service used to provide server certificate information for TLS (https) connections. Keystore must be configured on the service. If truststore is also configured, it will turn on and require client certificate authentication (Mutual TLS).

API Name

SSL Context Service

Service Interface

org.apache.nifi.ssl.RestrictedSSLContextService

Service Implementations

org.apache.nifi.ssl.StandardRestrictedSSLContextService

Expression Language Scope

Not Supported

Sensitive

false

Required

false

Dependencies
- Use TLS is set to any of [true]
Use TLS
Whether or not to use TLS to receive the contents of the gRPC messages.
Display Name

Use TLS

Description

Whether or not to use TLS to receive the contents of the gRPC messages.

API Name

Use TLS

Default Value

false

Allowable Values
- true
- false
Expression Language Scope

Not Supported

Sensitive

false

Required

false

Dynamic Properties

request$<FIELD.PATH>
The property name specifies the field in the request message whose value will be added as a FlowFile attribute with the name specified in the property's value (e.g. request$customer.name => customerName).

Name

request$<FIELD.PATH>

Description

The property name specifies the field in the request message whose value will be added as a FlowFile attribute with the name specified in the property's value (e.g. request$customer.name => customerName).

Value

FlowFile attribute name

Expression Language Scope

FLOWFILE_ATTRIBUTES

Relationships

Name	Description
success	The request message was received successfully.

Writes Attributes

Name	Description
listengrpc.remote.user.dn	The DN of the user who sent the FlowFile to this NiFi
listengrpc.remote.host	The IP of the client who sent the FlowFile to this NiFi