CloudWatch Integration with Fluentd


we are developing a SAS-based application. in the process, we have to collect all the logs generated from various containers in and route them to clodwatch service. since there is hard limit of 5 events per second per stream by cloudwatch. My question is how Fluentd can make sure all logs collected by it should be forwarded to cloudwatch in some reasonable time (say with 1 or 2 minutes since the log was generated by source containers)?


If you use @type cloudwatch_logs ( GitHub - fluent-plugins-nursery/fluent-plugin-cloudwatch-logs: CloudWatch Logs Plugin for Fluentd ),
How about tuning the value of max_events_per_batch ?