Stars
Forks
Watchers
Developer links
Apache NiFi
Deployed at thousands of enterprises across financial services, healthcare, government, and telecommunications, Apache NiFi is the industry-standard platform for building automated data pipelines through a visual drag-and-drop browser interface that requires zero coding for common integration patterns. The flow-based programming model connects over 300 built-in processors covering relational databases via ExecuteSQL and PutDatabaseRecord, Apache Kafka with PublishKafka and ConsumeKafka, HTTP endpoints through InvokeHTTP and ListenHTTP, cloud storage for AWS S3, Azure Blob, and Google Cloud Storage, SFTP/FTP file transfers, and JSON, XML, CSV, and Avro transformations. Data provenance tracking logs every routing decision, transformation, and delivery for every FlowFile, creating a searchable lineage graph from source to destination with full content replay capability for auditing and debugging. Guaranteed delivery uses configurable backpressure thresholds, prioritized queuing with latency or throughput optimization, and automatic retry with exponential backoff, ensuring no data loss even during downstream outages. The zero-leader clustering architecture distributes processing across nodes with automatic load balancing, while site-to-site protocol enables secure data transfer between NiFi instances across network boundaries. Security includes OpenID Connect and SAML 2.0 single sign-on, role-based access control with fine-grained policies per component, and TLS encryption for all communication. Custom processors can be written in Java and packaged as NAR bundles, or implemented directly in Python through the native scripting framework. Running on a dedicated VPS on RepoCloud with guaranteed CPU, RAM, and SSD, full root SSH access, and a browser serial console. Apache 2.0 licensed.
Benefits
- Visual Drag-and-Drop Pipeline Design
- Browser-based canvas lets users build complex data pipelines by connecting processors visually, with real-time monitoring of throughput, queue depth, and error rates without writing code.
- Complete Data Provenance Tracking
- Every FlowFile routing decision, transformation, and delivery is logged with searchable metadata, full content replay, and lineage graphs for compliance auditing and debugging.
- Guaranteed Delivery With Backpressure
- Configurable backpressure thresholds, prioritized queuing, and automatic retry with exponential backoff ensure zero data loss even during extended downstream system outages.
- 300+ Built-In Processors
- Pre-built processors cover SQL databases, Kafka, HTTP, S3, Azure Blob, SFTP, JSON, XML, CSV, and Avro with custom extensions via Java NAR bundles or native Python scripting.
Features
- Flow-Based Programming
- Processors connected by queued relationships form directed graphs with configurable prioritization, backpressure, and routing rules based on FlowFile attributes and content.
- Data Provenance
- Searchable history with configurable attribute filters records every processing event, enabling lineage graphs and content replay for auditing and compliance requirements.
- Zero-Leader Clustering
- Automatic load balancing distributes FlowFiles across cluster nodes without a single point of coordination, with site-to-site protocol for secure inter-instance transfers.
- Processor Library
- Over 300 processors for databases, messaging, cloud storage, HTTP, FTP, and data transformation formats with custom extension support via Java NAR bundles and Python.
- Security Framework
- OpenID Connect and SAML 2.0 single sign-on, fine-grained role-based access control per component, and TLS encryption for all intra-cluster and external communication.