diff --git a/pkg/events/events_batch.go b/pkg/events/events_batch.go
index 1c1f4efb8..269a2baeb 100644
--- a/pkg/events/events_batch.go
+++ b/pkg/events/events_batch.go
@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"context"
 	"errors"
+	"fmt"
 	"time"
 )
 
@@ -165,7 +166,7 @@ func (e *Events) batchWorker(ctx context.Context, id int) (err error) {
 				count = 0
 			}
 		case <-ctx.Done():
-			e.logger.Trace("batchWorker[", id, "]: exiting per context Done")
+			e.logger.Trace(fmt.Sprintf("batchWorker[%d]: exiting per context Done", id))
 			return ctx.Err()
 		}
 	}
diff --git a/pkg/logs/logs_batch.go b/pkg/logs/logs_batch.go
index c4ec91427..1e0e1374a 100644
--- a/pkg/logs/logs_batch.go
+++ b/pkg/logs/logs_batch.go
@@ -158,7 +158,7 @@ func (e *Logs) batchWorker(ctx context.Context, id int) (err error) {
 				count = 0
 			}
 		case <-ctx.Done():
-			e.logger.Trace("batchWorker[", id, "]: exiting per context Done")
+			e.logger.Trace(fmt.Sprintf("batchWorker[%d]: exiting per context Done", id))
 			return ctx.Err()
 		}
 	}