$ cat config.txt 
[SERVICE]
  daemon    Off
  log_level debug
  flush     1

[INPUT]
  Name   forward
  Listen 0.0.0.0
  Port   ${AGENT_PORT}

[FILTER]
  Name                           ecs
  Match                          *
  container_id_field_name        container_id
  ADD ecs_cluster                $ClusterName
  ADD ecs_task_id                $TaskID
  ADD ecs_container_name         $ECSContainerName
  ADD ecs_task_definition_family $TaskDefinitionFamily
  ADD ecs_task_id                $TaskID

[OUTPUT]
  Name               stdout
  Match              *
$ valgrind --leak-check=full  ./fluent-bit -c config.txt
==40== Memcheck, a memory error detector
==40== Copyright (C) 2002-2022, and GNU GPL'd, by Julian Seward et al.
==40== Using Valgrind-3.19.0 and LibVEX; rerun with -h for copyright info
==40== Command: ./fluent-bit -c config.txt
==40== 
Fluent Bit v3.1.0
* Copyright (C) 2015-2024 The Fluent Bit Authors
* Fluent Bit is a CNCF sub-project under the umbrella of Fluentd
* https://fluentbit.io

___________.__                        __    __________.__  __          ________  
\_   _____/|  |  __ __   ____   _____/  |_  \______   \__|/  |_  ___  _\_____  \ 
 |    __)  |  | |  |  \_/ __ \ /    \   __\  |    |  _/  \   __\ \  \/ / _(__  < 
 |     \   |  |_|  |  /\  ___/|   |  \  |    |    |   \  ||  |    \   / /       \
 \___  /   |____/____/  \___  >___|  /__|    |______  /__||__|     \_/ /______  /
     \/                     \/     \/               \/                        \/ 

[2024/07/02 16:05:48] [ warn] [env] variable ${AGENT_PORT} is used but not set
[2024/07/02 16:05:48] [ info] Configuration:
[2024/07/02 16:05:48] [ info]  flush time     | 1.000000 seconds
[2024/07/02 16:05:48] [ info]  grace          | 5 seconds
[2024/07/02 16:05:48] [ info]  daemon         | 0
[2024/07/02 16:05:48] [ info] ___________
[2024/07/02 16:05:48] [ info]  inputs:
[2024/07/02 16:05:48] [ info]      forward
[2024/07/02 16:05:48] [ info] ___________
[2024/07/02 16:05:48] [ info]  filters:
[2024/07/02 16:05:48] [ info]      ecs.0
[2024/07/02 16:05:48] [ info] ___________
[2024/07/02 16:05:48] [ info]  outputs:
[2024/07/02 16:05:48] [ info]      stdout.0
[2024/07/02 16:05:48] [ info] ___________
[2024/07/02 16:05:48] [ info]  collectors:
[2024/07/02 16:05:48] [ info] [fluent bit] version=3.1.0, commit=d597ecf2f2, pid=40
[2024/07/02 16:05:48] [debug] [engine] coroutine stack size: 24576 bytes (24.0K)
[2024/07/02 16:05:48] [ info] [storage] ver=1.5.2, type=memory, sync=normal, checksum=off, max_chunks_up=128
[2024/07/02 16:05:48] [ info] [cmetrics] version=0.9.1
[2024/07/02 16:05:48] [ info] [ctraces ] version=0.5.1
[2024/07/02 16:05:48] [ info] [input:forward:forward.0] initializing
[2024/07/02 16:05:48] [ info] [input:forward:forward.0] storage_strategy='memory' (memory only)
[2024/07/02 16:05:48] [debug] [forward:forward.0] created event channels: read=21 write=22
[2024/07/02 16:05:48] [debug] [in_fw] Listen='0.0.0.0' TCP_Port=24224
[2024/07/02 16:05:48] [debug] [downstream] listening on 0.0.0.0:24224
[2024/07/02 16:05:48] [ info] [input:forward:forward.0] listening on 0.0.0.0:24224
[2024/07/02 16:05:48] [debug] [filter:ecs:ecs.0] Using "container_id" field to retrieve container ID
[2024/07/02 16:05:48] [debug] [http_client] not using http_proxy for header
[2024/07/02 16:05:48] [debug] [filter:ecs:ecs.0] http_do=0, HTTP Status: 200
[2024/07/02 16:05:48] [debug] [stdout:stdout.0] created event channels: read=24 write=25
[2024/07/02 16:05:48] [ info] [sp] stream processor started
[2024/07/02 16:05:48] [ info] [output:stdout:stdout.0] worker #0 started
[2024/07/02 16:05:50] [debug] [http_client] not using http_proxy for header
[2024/07/02 16:05:50] [debug] [filter:ecs:ecs.0] http_do=0, HTTP Status: 200
[2024/07/02 16:05:50] [debug] [filter:ecs:ecs.0] Added `b36467ca05f0` to container metadata hash table
[2024/07/02 16:05:50] [debug] [task] created task=0x561f350 id=0 OK
[2024/07/02 16:05:50] [debug] [output:stdout:stdout.0] task_id=0 assigned to thread #0
", "ecs_cluster"=>"cluster-name-mock", "ecs_task_id"=>"620e42c10454441eac1afc0730a7ec54", "ecs_container_name"=>"container-name-mock", "ecs_task_definition_family"=>"tf-family-mock", "ecs_task_id"=>"620e42c10454441eac1afc0730a7ec54"}]
[2024/07/02 16:05:50] [debug] [out flush] cb_destroy coro_id=0
[2024/07/02 16:05:50] [debug] [task] destroy task=0x561f350 (task_id=0)
^C[2024/07/02 16:05:52] [engine] caught signal (SIGINT)
[2024/07/02 16:05:52] [ warn] [engine] service will shutdown in max 5 seconds
[2024/07/02 16:05:52] [ info] [input] pausing forward.0
[2024/07/02 16:05:52] [ info] [engine] service has stopped (0 pending tasks)
[2024/07/02 16:05:52] [ info] [input] pausing forward.0
[2024/07/02 16:05:52] [ info] [output:stdout:stdout.0] thread worker #0 stopping...
[2024/07/02 16:05:52] [ info] [output:stdout:stdout.0] thread worker #0 stopped
==40== 
==40== HEAP SUMMARY:
==40==     in use at exit: 0 bytes in 0 blocks
==40==   total heap usage: 2,068 allocs, 2,068 frees, 1,946,289 bytes allocated
==40== 
==40== All heap blocks were freed -- no leaks are possible
==40== 
==40== For lists of detected and suppressed errors, rerun with: -s
==40== ERROR SUMMARY: 0 errors from 0 contexts (suppressed: 0 from 0)