-
Processors
- AttributeRollingWindow
- AttributesToCSV
- AttributesToJSON
- CalculateParquetOffsets
- CalculateParquetRowGroupOffsets
- CalculateRecordStats
- CaptureChangeDebeziumDB2
- CaptureChangeDebeziumMongoDB
- CaptureChangeDebeziumMySQL
- CaptureChangeDebeziumOracle
- CaptureChangeDebeziumPostgreSQL
- CaptureChangeDebeziumSQLServer
- CaptureChangeMySQL
- CompressContent
- ConnectWebSocket
- ConsumeAMQP
- ConsumeAzureEventHub
- ConsumeBoxEnterpriseEvents
- ConsumeBoxEvents
- ConsumeElasticsearch
- ConsumeGCPubSub
- ConsumeIMAP
- ConsumeJMS
- ConsumeKafka
- ConsumeKafka_2_6
- ConsumeKafka2CDP
- ConsumeKafka2RecordCDP
- ConsumeKafkaRecord_2_6
- ConsumeKinesisStream
- ConsumeMQTT
- ConsumePLC
- ConsumePOP3
- ConsumeSlack
- ConsumeTwitter
- ConsumeWindowsEventLog
- ControlRate
- ConvertAvroToParquet
- ConvertCharacterSet
- ConvertProtobuf
- ConvertRecord
- CopyAzureBlobStorage_v12
- CopyS3Object
- CountText
- CreateHadoopSequenceFile
- CryptographicHashContent
- DebugFlow
- DecryptContentAge
- DecryptContentPGP
- DeduplicateRecord
- DeleteAzureBlobStorage_v12
- DeleteAzureDataLakeStorage
- DeleteByQueryElasticsearch
- DeleteCDPObjectStore
- DeleteDynamoDB
- DeleteFile
- DeleteGCSObject
- DeleteGridFS
- DeleteHBaseCells
- DeleteHBaseRow
- DeleteHDFS
- DeleteMongo
- DeleteS3Object
- DeleteSFTP
- DeleteSQS
- DetectDuplicate
- DistributeLoad
- DuplicateFlowFile
- EncodeContent
- EncryptContentAge
- EncryptContentPGP
- EnforceOrder
- EvaluateJsonPath
- EvaluateXPath
- EvaluateXQuery
- ExecuteGraphQuery
- ExecuteGraphQueryRecord
- ExecuteGroovyScript
- ExecuteProcess
- ExecuteScript
- ExecuteSparkInteractive
- ExecuteSQL
- ExecuteSQLRecord
- ExecuteStreamCommand
- ExtractAvroMetadata
- ExtractDocumentText
- ExtractEmailAttachments
- ExtractEmailHeaders
- ExtractGrok
- ExtractHL7Attributes
- ExtractImageMetadata
- ExtractMediaMetadata
- ExtractRecordSchema
- ExtractText
- FetchAzureBlobStorage_v12
- FetchAzureDataLakeStorage
- FetchBoxFile
- FetchBoxFileInfo
- FetchBoxFileRepresentation
- FetchCDPObjectStore
- FetchDistributedMapCache
- FetchDropbox
- FetchFile
- FetchFTP
- FetchGCSObject
- FetchGoogleDrive
- FetchGridFS
- FetchHBaseRow
- FetchHDFS
- FetchParquet
- FetchPLC
- FetchS3Object
- FetchSFTP
- FetchSmb
- FilterAttribute
- FlattenJson
- ForkEnrichment
- ForkRecord
- GenerateFlowFile
- GenerateRecord
- GenerateTableFetch
- GeoEnrichIP
- GeoEnrichIPRecord
- GeohashRecord
- GetAsanaObject
- GetAwsPollyJobStatus
- GetAwsTextractJobStatus
- GetAwsTranscribeJobStatus
- GetAwsTranslateJobStatus
- GetAzureEventHub
- GetAzureQueueStorage_v12
- GetBoxFileCollaborators
- GetBoxGroupMembers
- GetCouchbaseKey
- GetDynamoDB
- GetElasticsearch
- GetFile
- GetFileResource
- GetFTP
- GetGcpVisionAnnotateFilesOperationStatus
- GetGcpVisionAnnotateImagesOperationStatus
- GetHBase
- GetHDFS
- GetHDFSEvents
- GetHDFSFileInfo
- GetHDFSSequenceFile
- GetHubSpot
- GetJiraIssue
- GetMongo
- GetMongoRecord
- GetS3ObjectMetadata
- GetS3ObjectTags
- GetSFTP
- GetShopify
- GetSlackReaction
- GetSmbFile
- GetSNMP
- GetSnowflakeIngestStatus
- GetSolr
- GetSplunk
- GetSQS
- GetTCP
- GetWorkdayReport
- GetZendesk
- HandleHttpRequest
- HandleHttpResponse
- IdentifyMimeType
- InvokeGRPC
- InvokeHTTP
- InvokeScriptedProcessor
- ISPEnrichIP
- JoinEnrichment
- JoltTransformJSON
- JoltTransformRecord
- JSLTTransformJSON
- JsonQueryElasticsearch
- ListAzureBlobStorage_v12
- ListAzureDataLakeStorage
- ListBoxFile
- ListBoxFileInfo
- ListCDPObjectStore
- ListDatabaseTables
- ListDropbox
- ListenBeats
- ListenFTP
- ListenGRPC
- ListenHTTP
- ListenNetFlow
- ListenOTLP
- ListenSlack
- ListenSyslog
- ListenTCP
- ListenTrapSNMP
- ListenUDP
- ListenUDPRecord
- ListenWebSocket
- ListFile
- ListFTP
- ListGCSBucket
- ListGoogleDrive
- ListHBaseRegions
- ListHDFS
- ListS3
- ListSFTP
- ListSmb
- LogAttribute
- LogMessage
- LookupAttribute
- LookupRecord
- MergeContent
- MergeRecord
- ModifyBytes
- ModifyCompression
- MonitorActivity
- MoveAzureDataLakeStorage
- MoveHDFS
- Notify
- PackageFlowFile
- PaginatedJsonQueryElasticsearch
- ParseEvtx
- ParseNetflowv5
- ParseSyslog
- ParseSyslog5424
- PartitionRecord
- PublishAMQP
- PublishGCPubSub
- PublishJMS
- PublishKafka
- PublishKafka_2_6
- PublishKafka2CDP
- PublishKafka2RecordCDP
- PublishKafkaRecord_2_6
- PublishMQTT
- PublishSlack
- PutAccumuloRecord
- PutAzureBlobStorage_v12
- PutAzureCosmosDBRecord
- PutAzureDataExplorer
- PutAzureDataLakeStorage
- PutAzureEventHub
- PutAzureQueueStorage_v12
- PutBigQuery
- PutBoxFile
- PutCassandraQL
- PutCassandraRecord
- PutCDPObjectStore
- PutClouderaHiveQL
- PutClouderaHiveStreaming
- PutClouderaORC
- PutCloudWatchMetric
- PutCouchbaseKey
- PutDatabaseRecord
- PutDistributedMapCache
- PutDropbox
- PutDynamoDB
- PutDynamoDBRecord
- PutElasticsearchJson
- PutElasticsearchRecord
- PutEmail
- PutFile
- PutFTP
- PutGCSObject
- PutGoogleDrive
- PutGridFS
- PutHBaseCell
- PutHBaseJSON
- PutHBaseRecord
- PutHDFS
- PutIceberg
- PutIcebergCDC
- PutIoTDBRecord
- PutJiraIssue
- PutKinesisFirehose
- PutKinesisStream
- PutKudu
- PutLambda
- PutMongo
- PutMongoBulkOperations
- PutMongoRecord
- PutParquet
- PutPLC
- PutRecord
- PutRedisHashRecord
- PutS3Object
- PutSalesforceObject
- PutSFTP
- PutSmbFile
- PutSnowflakeInternalStage
- PutSNS
- PutSolrContentStream
- PutSolrRecord
- PutSplunk
- PutSplunkHTTP
- PutSQL
- PutSQS
- PutSyslog
- PutTCP
- PutUDP
- PutWebSocket
- PutZendeskTicket
- QueryAirtableTable
- QueryAzureDataExplorer
- QueryCassandra
- QueryDatabaseTable
- QueryDatabaseTableRecord
- QueryIoTDBRecord
- QueryRecord
- QuerySalesforceObject
- QuerySolr
- QuerySplunkIndexingStatus
- RemoveRecordField
- RenameRecordField
- ReplaceText
- ReplaceTextWithMapping
- ResizeImage
- RetryFlowFile
- RouteHL7
- RouteOnAttribute
- RouteOnContent
- RouteText
- RunMongoAggregation
- SampleRecord
- SawmillTransformJSON
- SawmillTransformRecord
- ScanAccumulo
- ScanAttribute
- ScanContent
- ScanHBase
- ScriptedFilterRecord
- ScriptedPartitionRecord
- ScriptedTransformRecord
- ScriptedValidateRecord
- SearchElasticsearch
- SegmentContent
- SelectClouderaHiveQL
- SendTrapSNMP
- SetSNMP
- SignContentPGP
- SplitAvro
- SplitContent
- SplitExcel
- SplitJson
- SplitPCAP
- SplitRecord
- SplitText
- SplitXml
- StartAwsPollyJob
- StartAwsTextractJob
- StartAwsTranscribeJob
- StartAwsTranslateJob
- StartGcpVisionAnnotateFilesOperation
- StartGcpVisionAnnotateImagesOperation
- StartSnowflakeIngest
- TagS3Object
- TailFile
- TransformXml
- TriggerClouderaHiveMetaStoreEvent
- UnpackContent
- UpdateAttribute
- UpdateByQueryElasticsearch
- UpdateClouderaHiveTable
- UpdateCounter
- UpdateDatabaseTable
- UpdateDeltaLakeTable
- UpdateJiraIssue
- UpdateRecord
- ValidateCsv
- ValidateJson
- ValidateRecord
- ValidateXml
- VerifyContentMAC
- VerifyContentPGP
- Wait
-
Controller Services
- AccumuloService
- ActiveMQJMSConnectionFactoryProvider
- ADLSCredentialsControllerService
- ADLSCredentialsControllerServiceLookup
- ADLSIDBrokerCloudCredentialsProviderControllerService
- AmazonGlueSchemaRegistry
- ApicurioSchemaRegistry
- AvroReader
- AvroRecordSetWriter
- AvroSchemaRegistry
- AWSCredentialsProviderControllerService
- AWSIDBrokerCloudCredentialsProviderControllerService
- AzureBlobIDBrokerCloudCredentialsProviderControllerService
- AzureBlobStorageFileResourceService
- AzureCosmosDBClientService
- AzureDataLakeStorageFileResourceService
- AzureEventHubRecordSink
- AzureServiceBusJMSConnectionFactoryProvider
- AzureStorageCredentialsControllerService_v12
- AzureStorageCredentialsControllerServiceLookup_v12
- CassandraDistributedMapCache
- CassandraSessionProvider
- CdpCredentialsProviderControllerService
- CdpOauth2AccessTokenProviderControllerService
- CEFReader
- CiscoEmblemSyslogMessageReader
- ClouderaAttributeSchemaReferenceReader
- ClouderaAttributeSchemaReferenceWriter
- ClouderaEncodedSchemaReferenceReader
- ClouderaEncodedSchemaReferenceWriter
- ClouderaHiveConnectionPool
- ClouderaSchemaRegistry
- CMLLookupService
- ConfluentEncodedSchemaReferenceReader
- ConfluentEncodedSchemaReferenceWriter
- ConfluentSchemaRegistry
- CouchbaseClusterService
- CouchbaseKeyValueLookupService
- CouchbaseMapCacheClient
- CouchbaseRecordLookupService
- CSVReader
- CSVRecordLookupService
- CSVRecordSetWriter
- DatabaseRecordLookupService
- DatabaseRecordSink
- DatabaseTableSchemaRegistry
- DBCPConnectionPool
- DBCPConnectionPoolLookup
- DeveloperBoxClientService
- DistributedMapCacheLookupService
- EBCDICRecordReader
- ElasticSearchClientServiceImpl
- ElasticSearchLookupService
- ElasticSearchStringLookupService
- EmailRecordSink
- EmbeddedHazelcastCacheManager
- ExcelReader
- ExternalHazelcastCacheManager
- FreeFormTextRecordSetWriter
- GCPCredentialsControllerService
- GCSFileResourceService
- GenericPLC4XConnectionPool
- GrokReader
- HadoopCatalogService
- HadoopDBCPConnectionPool
- HazelcastMapCacheClient
- HBase_2_ClientMapCacheService
- HBase_2_ClientService
- HBase_2_RecordLookupService
- HikariCPConnectionPool
- HiveCatalogService
- HttpRecordSink
- ImpalaConnectionPool
- IPFIXReader
- IPLookupService
- JASN1Reader
- JdbcCatalogService
- JettyWebSocketClient
- JettyWebSocketServer
- JiraRecordSink
- JMSConnectionFactoryProvider
- JndiJmsConnectionFactoryProvider
- JsonConfigBasedBoxClientService
- JsonPathReader
- JsonRecordSetWriter
- JsonTreeReader
- Kafka3ConnectionService
- KafkaRecordSink_2_6
- KerberosKeytabUserService
- KerberosPasswordUserService
- KerberosTicketCacheUserService
- KuduLookupService
- LivySessionController
- LoggingRecordSink
- MapCacheClientService
- MapCacheServer
- MongoDBControllerService
- MongoDBLookupService
- Neo4JCypherClientService
- ParquetReader
- ParquetRecordSetWriter
- PEMEncodedSSLContextProvider
- PhoenixThickConnectionPool
- PhoenixThinConnectionPool
- PostgreSQLConnectionPool
- PropertiesFileLookupService
- ProtobufReader
- ProxyPLC4XConnectionPool
- RabbitMQJMSConnectionFactoryProvider
- ReaderLookup
- RecordSetWriterLookup
- RecordSinkServiceLookup
- RedisConnectionPoolService
- RedisDistributedMapCacheClientService
- RedshiftConnectionPool
- RESTCatalogService
- RestLookupService
- S3FileResourceService
- ScriptedLookupService
- ScriptedReader
- ScriptedRecordSetWriter
- ScriptedRecordSink
- SetCacheClientService
- SetCacheServer
- SimpleCsvFileLookupService
- SimpleDatabaseLookupService
- SimpleKeyValueLookupService
- SimpleRedisDistributedMapCacheClientService
- SimpleScriptedLookupService
- SiteToSiteReportingRecordSink
- SlackRecordSink
- SmbjClientProviderService
- SnowflakeComputingConnectionPool
- StandardAsanaClientProviderService
- StandardAzureCredentialsControllerService
- StandardDatabaseDialectService
- StandardDropboxCredentialService
- StandardFileResourceService
- StandardHashiCorpVaultClientService
- StandardHttpContextMap
- StandardJiraCredentialService
- StandardJsonSchemaRegistry
- StandardKustoIngestService
- StandardKustoQueryService
- StandardOauth2AccessTokenProvider
- StandardPGPPrivateKeyService
- StandardPGPPublicKeyService
- StandardPLC4XConnectionPool
- StandardPrivateKeyService
- StandardProxyConfigurationService
- StandardRestrictedSSLContextService
- StandardS3EncryptionService
- StandardSnowflakeIngestManagerProviderService
- StandardSSLContextService
- StandardWebClientServiceProvider
- Syslog5424Reader
- SyslogReader
- TinkerpopClientService
- UDPEventRecordSink
- VolatileSchemaCache
- WindowsEventLogReader
- XMLFileLookupService
- XMLReader
- XMLRecordSetWriter
- YamlTreeReader
- ZendeskRecordSink
-
Reporting Tasks
- AzureLogAnalyticsProvenanceReportingTask
- AzureLogAnalyticsReportingTask
- ControllerStatusReportingTask
- MonitorDiskUsage
- MonitorMemory
- QueryNiFiReportingTask
- ReportLineageToAtlas
- ScriptedReportingTask
- SiteToSiteBulletinReportingTask
- SiteToSiteMetricsReportingTask
- SiteToSiteProvenanceReportingTask
- SiteToSiteStatusReportingTask
-
Parameter Providers
- AwsSecretsManagerParameterProvider
- AzureKeyVaultSecretsParameterProvider
- CyberArkConjurParameterProvider
- DatabaseParameterProvider
- EnvironmentVariableParameterProvider
- GcpSecretManagerParameterProvider
- HashiCorpVaultParameterProvider
- KubernetesSecretParameterProvider
- OnePasswordParameterProvider
- PropertiesFileParameterProvider
-
Flow Analysis Rules
- DisallowComponentType
- DisallowConsecutiveConnectionsWithRoundRobinLB
- DisallowDeadEnd
- DisallowDeprecatedProcessor
- DisallowExtractTextForFullContent
- RecommendRecordProcessor
- RequireHandleHttpResponseAfterHandleHttpRequest
- RequireMergeBeforePutIceberg
- RestrictBackpressureSettings
- RestrictComponentNaming
- RestrictConcurrentTasksVsThreadPoolSizeInProcessors
- RestrictFlowFileExpiration
- RestrictProcessorConcurrency
- RestrictSchedulingForListProcessors
- RestrictThreadPoolSize
- RestrictYieldDurationForConsumeKafkaProcessors
ConfluentEncodedSchemaReferenceWriter 2.3.0.4.10.0.0-147
- Bundle
- org.apache.nifi | nifi-confluent-platform-nar
- Description
- Writes Schema Identifier according to Confluent encoding as a header consisting of a byte marker and an integer represented as four bytes
- Tags
- avro, confluent, kafka, registry, schema
- Input Requirement
- Supports Sensitive Dynamic Properties
- false
Properties