awesome-repositories.com
Blog
MCP
awesome-repositories.com

Discover the best open-source repositories with AI-powered search.

ExploreCurated searchesOpen-source alternativesSelf-hosted softwareBlogSitemap
ProjectMCP serverAboutHow we rankPress
LegalPrivacyTerms
© 2026 Bringes Technology SRL·VAT RO45896025·hello@awesome-repositories.com
fluent avatar

fluent/fluentd

0
View on GitHub↗
13,554 stars·1,390 forks·Ruby·Apache-2.0·33 viewswww.fluentd.org↗

Fluentd

Fluentd is a unified logging layer and distributed event router that collects, parses, and routes log data from diverse sources to various storage backends. It functions as a log forwarding agent and pipeline orchestrator, transforming raw unstructured log strings into formatted objects using structured log parsing.

The project utilizes a plugin-based pipeline architecture to route data through independent input, filter, and output stages. It differentiates itself through tag-based event routing, which uses regular expression patterns to direct specific data streams to their intended destinations.

Its capabilities cover wide-ranging data collection via HTTP, TCP, UDP, and local file tailing, as well as the processing of system logs following RFC standards. The system includes internal monitoring for throughput and buffer usage, as well as mechanisms for event buffering and compression to prevent data loss during traffic spikes or output failures.

Pipelines are defined using a structured configuration format supporting YAML or a domain-specific language.

Features

  • Monitoring and Logging - Aggregates logs from diverse sources and routes them to central storage backends for unified analysis.
  • Log Routing - Gathers log information from diverse sources, parses it, and routes it to multiple storage backends.
  • Data Pipeline Configurations - Defines data pipelines using a structured configuration format supporting YAML and a domain-specific language.
  • Distributed Event Routers - Directs data streams to specific output destinations by matching event labels against regular expression patterns.
  • Log Aggregators - Functions as a unified logging layer that centralizes logs from distributed sources into unified stores.
  • Log Storage Engines - Routes gathered log events to various storage backends, including databases, cloud services, and files.
  • Record Transformers - Modifies event content by parsing fields, filtering records via grep, or changing record structures.
  • Unstructured Data Transformation Tools - Transforms raw unstructured log strings into structured data formats using regular expressions and specialized parsers.
  • Tag-Based Routing - Directs log events to specific output destinations using regular expression matches against event tags.
  • Plugin-Based Architectures - Implements a modular architecture where data flows through a sequence of independent input, filter, and output plugins.
  • Telemetry and Log Collectors - Receives and captures log data via HTTP, TCP, and UDP sockets for centralized processing.
  • Log Transformation Pipelines - Modifies and enriches log entries during ingestion to transform raw strings into structured, searchable formats.
  • Log Parsers - Transforms raw log strings into structured formats using regular expressions, JSON, and syslog parsers.
  • Log Processing Pipelines - Orchestrates the parsing, normalizing, and structuring of raw log data using customizable pipelines.
  • Label-Based Routing - Directs log data streams to specific output destinations based on event labels and regular expression patterns.
  • Log Forwarders - Acts as a lightweight agent that monitors and transmits logs from local disks or sockets to remote endpoints.
  • Observability Pipelines - Builds reliable data pipelines that buffer and filter logs to ensure delivery to monitoring platforms.
  • Syslog Ingestion - Processes system log messages following RFC3164 and RFC5424 formatting standards.
  • Inode-Based Tracking - Tracks log files via unique filesystem identifiers to ensure continuous reading across file rotations and renames.
  • Event Buffering - Provides mechanisms to temporarily store event streams in memory or on disk to prevent data loss during spikes.
  • Process Scaling - Distributes processing load across multiple independent processes to maximize throughput and enable zero-downtime restarts.
  • Pipeline Plugins - Implements a pipeline architecture where data flows through a sequence of independent input, filter, and output plugins.
  • HTTP Log Ingestion - Receives log data via HTTP requests using JSON, msgpack, or NDJSON payloads.
  • Log File Tailing - Tails log files from disk and emits new lines as events using glob patterns and inode tracking.
  • Internal Telemetry Monitors - Tracks internal operational state, including input throughput, buffer usage, and dropped event counts.
  • Process Lifecycle Managers - Manages the lifecycle of worker processes to enable zero-downtime restarts and scaling.
  • Remote Log Transmission - Pushes log data to remote web endpoints using connection reuse and secure request signing.
  • TCP/UDP Log Ingestion - Listens for incoming log data on TCP or UDP sockets with configurable message length limits.
  • Data Collection Agents - Unified logging layer for collecting and consuming data.
  • Log Management - Unified logging layer for data collection.
  • Logging And Aggregation - Unified logging layer for cloud-native systems.
  • Log Management - Unified logging layer for data collection.
  • Observability and Monitoring - Unified logging layer for data collection.
  • Logging - Collects and routes events from various data sources.

Star history

Star history chart for fluent/fluentdStar history chart for fluent/fluentd

How this analysis was created: This summary and feature list are AI-generated from collected project material and can contain mistakes. Stars, license and language are imported from GitHub. Inclusion does not mean that we have tested or audited this project. Check the source documentation for any feature you depend on. Learn more on our About page.

AI search

Explore more awesome repositories

Describe what you need in plain English — the AI ranks thousands of curated open-source projects by relevance.

Start searching with AI

Frequently asked questions

What does fluent/fluentd do?

Fluentd is a unified logging layer and distributed event router that collects, parses, and routes log data from diverse sources to various storage backends. It functions as a log forwarding agent and pipeline orchestrator, transforming raw unstructured log strings into formatted objects using structured log parsing.

What are the main features of fluent/fluentd?

The main features of fluent/fluentd are: Monitoring and Logging, Log Routing, Data Pipeline Configurations, Distributed Event Routers, Log Aggregators, Log Storage Engines, Record Transformers, Unstructured Data Transformation Tools.

Which projects share features with fluent/fluentd?

Projects with overlapping indexed features include: vectordotdev/vector — Vector is a high-performance observability data pipeline designed to collect, transform, and route logs, metrics, and… grafana/loki — Loki is a horizontally scalable, highly available log aggregation engine designed to store and query massive volumes… victoriametrics/victoriametrics — VictoriaMetrics is a high-performance, scalable time series database and observability platform designed for long-term… uptrace/uptrace — Uptrace is an OpenTelemetry-based observability platform designed to collect, store, and analyze distributed traces,… elastic/logstash — Logstash is a JVM-based event processor and extract, transform, load system designed for log data processing… fluent/fluent-bit — Fluent Bit is a cloud-native log shipper and unified telemetry collector designed as a resource-efficient data…

Projects sharing features with Fluentd

These projects share indexed features with Fluentd. Shared tags can include platform or build tooling; verify the primary use case before treating a result as a replacement.
  • vectordotdev/vectorvectordotdev avatar

    vectordotdev/vector

    22,071View on GitHub↗

    Vector is a high-performance observability data pipeline designed to collect, transform, and route logs, metrics, and traces across distributed infrastructure. It functions as a modular engine that decouples data ingestion from processing and transmission, utilizing a component-based architecture to connect diverse sources to multiple destinations. The project distinguishes itself through a focus on reliability and flow control. It implements backpressure-aware data movement to prevent data loss during traffic spikes and utilizes disk-backed event buffering to ensure durability during network

    Rusteventsforwarderhacktoberfest
    View on GitHub↗22,071
  • grafana/lokigrafana avatar

    grafana/loki

    27,640View on GitHub↗

    Loki is a horizontally scalable, highly available log aggregation engine designed to store and query massive volumes of unstructured log data. It functions as a distributed observability platform that correlates logs, metrics, and traces to provide comprehensive visibility into the health and performance of complex infrastructure. The system distinguishes itself through a distributed query execution model that processes large datasets in parallel across cluster nodes. It utilizes label-based stream indexing and a distributed index to map log data to specific chunks, enabling rapid retrieval w

    Gocloudnativegrafanahacktoberfest
    View on GitHub↗27,640
  • victoriametrics/victoriametricsVictoriaMetrics avatar

    VictoriaMetrics/VictoriaMetrics

    16,343View on GitHub↗

    VictoriaMetrics is a high-performance, scalable time series database and observability platform designed for long-term storage and analysis of metric, log, and trace data. It functions as a unified backend for monitoring ecosystems, offering full compatibility with industry-standard protocols and query languages. The system is built to handle massive data volumes through a distributed architecture that supports horizontal scaling and efficient data lifecycle management. The platform distinguishes itself through a storage engine that utilizes consistent hashing for data sharding and log-struct

    Godatabasegrafanagraphite
    View on GitHub↗16,343
  • uptrace/uptraceuptrace avatar

    uptrace/uptrace

    4,098View on GitHub↗

    Uptrace is an OpenTelemetry-based observability platform designed to collect, store, and analyze distributed traces, metrics, and logs. It functions as a centralized logging backend, a distributed tracing system, and a metrics engine to monitor application performance and system health. The platform is distinguished by AI-powered operational capabilities, allowing users to query telemetry data and manage monitoring dashboards using natural language. It specifically includes specialized monitoring for generative AI pipelines, tracking token usage and response quality for LLM interactions and r

    Goapmapplication-monitoringclickhouse
    View on GitHub↗4,098
Compare all 30 related projects→