diff --git a/telemetry/fluent-bit/fluent_bit.go b/telemetry/fluent-bit/fluent_bit.go
index 09deca20..deeeaeaf 100644
--- a/telemetry/fluent-bit/fluent_bit.go
+++ b/telemetry/fluent-bit/fluent_bit.go
@@ -37,10 +37,11 @@ func New(config *config.RegistryConfig) (FluentBit, error) {
 	}
 
 	fbClient := &fluentBit{
-		client: httpClient,
-		config: config,
-		wg:     sync.WaitGroup{},
-		gate:   make(chan struct{}, 5),
+		client:        httpClient,
+		config:        config,
+		wg:            sync.WaitGroup{},
+		gate:          make(chan struct{}, 5),
+		retryMessages: make(map[string]retryLogMsg),
 	}
 
 	go fbClient.retry()