This article describes how to optimize Fluentd's performance within single process. If your traffic is up to 5,000 messages/sec, the following techniques should be enough.
With more traffic, Fluentd tends to be more CPU bound. In such case, please consider using "multi-worker" feature.
Please follow the Preinstallation Guide to configure your OS properly. This can drastically improve the performance, and prevent many unnecessary problems.
If Fluentd doesn't perform as well as you had expected, please check the
top command first. You need to identify which part of your system is the bottleneck (CPU? Memory? Disk I/O? etc).
This is more like a general recommendation, but it's always better NOT TO HAVE extra computation inside Fluentd. Fluentd is flexible to do quite a bit internally, but adding too much logic to Fluentd's configuration file makes it difficult to read and maintain, while making it also less robust. The configuration file should be as simple as possible.
If the destination for your logs is a remote storage or service, adding a
flush_thread_count option will parallelize your outputs (the default is 1). Using multiple threads can hide the IO/network latency. This parameter is available for all output plugins.
<match test>@type output_plugin<buffer ...>flush_thread_count 8...</buffer>...</match>
The important point is this option doesn't improve the processing performance, e.g. numerical computation, mutating record, etc.
Ruby has GIL (Global Interpreter Lock), which allows only one thread to execute at a time. While I/O tasks can be multiplexed, CPU-intensive tasks will block other jobs. One of the CPU-intensive tasks in Fluentd is compression.
The S3/Treasure Data plugin allows compression outside of the Fluentd process, using gzip. This frees up the Ruby interpreter while allowing Fluentd to process other tasks.
# S3<match ...>@type s3store_as gzip_command<buffer ...>flush_thread_count 8...</buffer>...</match># Treasure Data<match ...>@type tdloguse_gzip_command<buffer ...>flush_thread_count 8...</buffer>...</match>
While not a perfect solution to leverage multiple CPU cores, this can be effective for most Fluentd deployments. As before, you can run this with
flush_thread_count option as well.
Ruby has several GC parameters to tune GC performance and you can configure these parameters via environment variable(Parameter list is here). To reduce memory usage, set
RUBY_GC_HEAP_OLDOBJECT_LIMIT_FACTOR to lower value.
RUBY_GC_HEAP_OLDOBJECT_LIMIT_FACTOR is used for full GC trigger and the default is
2.0. Quote from documentation.
Do full GC when the number of old objects is more than R * Nwhere R is this factor andN is the number of old objects just after last full GC.
So default GC behaviour doesn't call full GC until the number of old objects reaches
2.0 * before old objects. This improves the throughput but it grows the total memory usage. This setting is not good for low resource environment, e.g. small container. For such cases, try
See Ruby 2.1 Garbage Collection: ready for production and Watching and Understanding the Ruby 2.1 Garbage Collector at Work article for more detail.
The CPU is often the bottleneck for Fluentd instances that handle billions of incoming records. To utilize multiple CPU cores, we recommend using
multi workers feature.
For the details of this feature, please read multi process workers article.
If this article is incorrect or outdated, or omits critical information, please let us know. Fluentd is a open source project under Cloud Native Computing Foundation (CNCF). All components are available under the Apache 2 License.