ADLSCredentialsControllerService
Defines credentials for ADLS processors.
ADLSCredentialsControllerServiceLookup
Provides an ADLSCredentialsService that can be used to dynamically select another ADLSCredentialsService
AmazonGlueSchemaRegistry
Provides a Schema Registry that interacts with the AWS Glue Schema Registry so that those Schemas that are stored in the Glue Schema Registry can be used in NiFi
AmazonMSKConnectionService
Provides and manages connections to AWS MSK Kafka Brokers for producer or consumer operations.
ApicurioSchemaRegistry
Provides a Schema Registry that interacts with the Apicurio Schema Registry so that those Schemas that are stored in the Apicurio Schema Registry can be used in NiFi
AvroReader
Parses Avro data and returns each Avro record as an separate Record object
AvroRecordSetWriter
Writes the contents of a RecordSet in Binary Avro format.
AvroSchemaRegistry
Provides a service for registering and accessing schemas
AWSCredentialsProviderControllerService
Defines credentials for Amazon Web Services processors
AzureBlobStorageFileResourceService
Provides an Azure Blob Storage file resource for other components.
AzureCosmosDBClientService
Provides a controller service that configures a connection to Cosmos DB (Core SQL API) and provides access to that connection to other Cosmos DB-related components.
AzureDataLakeStorageFileResourceService
Provides an Azure Data Lake Storage (ADLS) file resource for other components.
AzureEventHubRecordSink
Format and send Records to Azure Event Hubs
AzureStorageCredentialsControllerService_v12
Provides credentials for Azure Storage processors using Azure Storage client library v12.
AzureStorageCredentialsControllerServiceLookup_v12
Provides an AzureStorageCredentialsService_v12 that can be used to dynamically select another AzureStorageCredentialsService_v12
CEFReader
Parses CEF (Common Event Format) events, returning each row as a record
ConfluentEncodedSchemaReferenceReader
Reads Schema Identifier according to Confluent encoding as a header consisting of a byte marker and an integer represented as four bytes
ConfluentEncodedSchemaReferenceWriter
Writes Schema Identifier according to Confluent encoding as a header consisting of a byte marker and an integer represented as four bytes
ConfluentSchemaRegistry
Provides a Schema Registry that interacts with the Confluent Schema Registry so that those Schemas that are stored in the Confluent Schema Registry can be used in NiFi
CSVReader
Parses CSV-formatted data, returning each row in the CSV file as a separate record
CSVRecordLookupService
A reloadable CSV file-based lookup service
CSVRecordSetWriter
Writes the contents of a RecordSet as CSV data
DatabaseLookup
A Lookup Service that allows for enrichment with a database using a user-specified SQL statement
DatabaseRecordLookupService
A relational-database-based lookup service
DatabaseRecordSink
Provides a service to write records using a configured database connection.
DBCPConnectionPool
Provides Database Connection Pooling Service
DBCPConnectionPoolLookup
Provides a DBCPService that can be used to dynamically select another DBCPService
DistributedMapCacheLookupService
Allows to choose a distributed map cache client to retrieve the value associated to a key
ElasticSearchClientServiceImpl
A controller service for accessing an Elasticsearch client, using the Elasticsearch (low-level) REST Client.
ElasticSearchLookupService
Lookup a record from Elasticsearch Server associated with the specified document ID
ElasticSearchStringLookupService
Lookup a string value from Elasticsearch Server associated with the specified document ID
EmailRecordSink
Provides a RecordSinkService that can be used to send records in email using the specified writer for formatting.
EmbeddedHazelcastCacheManager
A service that runs embedded Hazelcast and provides cache instances backed by that
ExcelReader
Parses a Microsoft Excel document returning each row in each sheet as a separate record
ExternalHazelcastCacheManager
A service that provides cache instances backed by Hazelcast running outside of NiFi.
FreeFormTextRecordSetWriter
Writes the contents of a RecordSet as free-form text
GCPCredentialsControllerService
Defines credentials for Google Cloud Platform processors
GCSFileResourceService
Provides a Google Compute Storage (GCS) file resource for other components.
GrokReader
Provides a mechanism for reading unstructured text data, such as log files, and structuring the data so that it can be processed
HazelcastMapCacheClient
An implementation of DistributedMapCacheClient that uses Hazelcast as the backing cache
HikariCPConnectionPool
Provides Database Connection Pooling Service based on HikariCP
HttpRecordSink
Format and send Records to a configured uri using HTTP post
IPLookupService
A lookup service that provides several types of enrichment information for IP addresses
JettyWebSocketClient
Implementation of WebSocketClientService
JettyWebSocketServer
Implementation of WebSocketServerService
JMSConnectionFactoryProvider
Provides a generic service to create vendor specific javax.jms.ConnectionFactory implementations
JndiJmsConnectionFactoryProvider
Provides a service to lookup an existing JMS ConnectionFactory using the Java Naming and Directory Interface (JNDI).
JsonConfigBasedBoxClientService
Provides Box client objects through which Box API calls can be used.
JsonPathReader
Parses JSON records and evaluates user-defined JSON Path's against each JSON object
JsonRecordSetWriter
Writes the results of a RecordSet as either a JSON Array or one JSON object per line
JsonTreeReader
Parses JSON into individual Record objects
Kafka3ConnectionService
Provides and manages connections to Kafka Brokers for producer or consumer operations.
LoggingRecordSink
Provides a RecordSinkService that can be used to log records to the application log (nifi-app.log, e.g.) using the specified writer for formatting.
MapCacheClientService
Provides the ability to communicate with a MapCacheServer
MapCacheServer
Provides a map (key/value) cache that can be accessed over a socket
MicrosoftGraphAuthenticationProvider
Provides authentication for the Microsoft Graph API, which can be used for interacting with Microsoft 365 services.
MongoDBControllerService
Provides a controller service that configures a connection to MongoDB and provides access to that connection to other Mongo-related components.
MongoDBLookupService
Provides a lookup service based around MongoDB
ParquetIcebergWriter
Provides record serialization for Apache Iceberg using Apache Parquet formatting
PolarisIcebergCatalog
Provides Apache Iceberg integration with Apache Polaris Catalog access over REST HTTP
PropertiesFileLookupService
A reloadable properties file-based lookup service
ReaderLookup
Provides a RecordReaderFactory that can be used to dynamically select another RecordReaderFactory
RecordSetWriterLookup
Provides a RecordSetWriterFactory that can be used to dynamically select another RecordSetWriterFactory
RecordSinkServiceLookup
Provides a RecordSinkService that can be used to dynamically select another RecordSinkService
RedisConnectionPoolService
A service that provides connections to Redis.
RedisDistributedMapCacheClientService
An implementation of DistributedMapCacheClient that uses Redis as the backing cache
RestLookupService
Use a REST service to look up values.
S3FileResourceService
Provides an Amazon Web Services (AWS) S3 file resource for other components.
ScriptedLookupService
Allows the user to provide a scripted LookupService instance in order to enrich records from an incoming flow file.
ScriptedReader
Allows the user to provide a scripted RecordReaderFactory instance in order to read/parse/generate records from an incoming flow file.
ScriptedRecordSetWriter
Allows the user to provide a scripted RecordSetWriterFactory instance in order to write records to an outgoing flow file.
ScriptedRecordSink
Allows the user to provide a scripted RecordSinkService instance in order to transmit records to the desired target
SetCacheClientService
Provides the ability to communicate with a SetCacheServer
SetCacheServer
Provides a set (collection of unique values) cache that can be accessed over a socket
SimpleCsvFileLookupService
A reloadable CSV file-based lookup service
SimpleDatabaseLookupService
A relational-database-based lookup service
SimpleKeyValueLookupService
Allows users to add key/value pairs as User-defined Properties
SimpleRedisDistributedMapCacheClientService
An implementation of DistributedMapCacheClient that uses Redis as the backing cache
SimpleScriptedLookupService
Allows the user to provide a scripted LookupService instance in order to enrich records from an incoming flow file
SlackRecordSink
Format and send Records to a configured Channel using the Slack Post Message API
SmbjClientProviderService
Provides access to SMB Sessions with shared authentication credentials.
SnowflakeConnectionService
Provides pooled database connections to Snowflake services
StandardAnthropicLLMService
A Controller Service that provides integration with Anthropic's Claude AI models through their Messages API
StandardAzureCredentialsControllerService
Provide credentials to use with an Azure client.
StandardDatabricksWorkspaceClientService
Databricks client.
StandardDropboxCredentialService
Defines credentials for Dropbox processors.
StandardFileResourceService
Provides a file resource for other components
StandardHashiCorpVaultClientService
A controller service for interacting with HashiCorp Vault.
StandardHttpContextMap
Provides the ability to store and retrieve HTTP requests and responses external to a Processor, so that multiple Processors can interact with the same HTTP request.
StandardHubSpotClientService
HubSpot Controller Service to integrate with HubSpot HTTP api.
StandardJsonSchemaRegistry
Provides a service for registering and accessing JSON schemas
StandardKustoIngestService
Sends batches of flowfile content or stream flowfile content to an Azure ADX cluster.
StandardKustoQueryService
Standard implementation of Kusto Query Service for Azure Data Explorer
StandardMilvusConnectionService
Provides connection service to a Milvus instance
StandardOauth2AccessTokenProvider
Provides OAuth 2.0 access tokens that can be used as Bearer authorization header in HTTP requests
StandardOCRService
Provides integration to Datavolo OCR Service
StandardOpenAILLMService
A Controller Service that provides integration with OpenAI's Chat Completion API
StandardPGPPrivateKeyService
PGP Private Key Service provides Private Keys loaded from files or properties
StandardPGPPublicKeyService
PGP Public Key Service providing Public Keys loaded from files
StandardPrivateKeyService
Private Key Service provides access to a Private Key loaded from configured sources
StandardProxyConfigurationService
Provides a set of configurations for different NiFi components to use a proxy server.
StandardRestrictedSSLContextService
Restricted implementation of the SSLContextService
StandardS3EncryptionService
Adds configurable encryption to S3 Put and S3 Fetch operations.
StandardSSLContextService
Standard implementation of the SSLContextService
StandardVectaraClientService
Vectara Controller Service to integrate with Vectara HTTP Api.
StandardWebClientServiceProvider
Web Client Service Provider with support for configuring standard HTTP connection properties
Syslog5424Reader
Provides a mechanism for reading RFC 5424 compliant Syslog data, such as log files, and structuring the data so that it can be processed.
SyslogReader
Attempts to parses the contents of a Syslog message in accordance to RFC5424 and RFC3164
UDPEventRecordSink
Format and send Records as UDP Datagram Packets to a configurable destination
VolatileSchemaCache
Provides a Schema Cache that evicts elements based on a Least-Recently-Used algorithm
WindowsEventLogReader
Reads Windows Event Log data as XML content having been generated by ConsumeWindowsEventLog, ParseEvtx, etc
XMLFileLookupService
A reloadable XML file-based lookup service
XMLReader
Reads XML content and creates Record objects
XMLRecordSetWriter
Writes a RecordSet to XML
YamlTreeReader
Parses YAML into individual Record objects