kgo tests: add timestamps

twmb · Oct 21, 2023 · 5cfb6a5 · 5cfb6a5
1 parent d520096
commit 5cfb6a5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/pkg/kgo/helpers_test.go b/pkg/kgo/helpers_test.go
@@ -89,7 +89,7 @@ func testLogger() Logger {
 	num := loggerNum.Add(1)
 	pfx := strconv.Itoa(int(num))
 	return BasicLogger(os.Stderr, testLogLevel, func() string {
-		return time.Now().Format("[15:04:05 ") + pfx + "]"
+		return time.Now().UTC().Format("[15:04:05.999 ") + pfx + "]"
 	})
 }
 

diff --git a/pkg/kgo/txn_test.go b/pkg/kgo/txn_test.go
@@ -28,7 +28,9 @@ func TestTxnEtl(t *testing.T) {
 	go func() {
 		cl, err := NewClient(
 			getSeedBrokers(),
-			WithLogger(BasicLogger(os.Stderr, testLogLevel, nil)),
+			WithLogger(BasicLogger(os.Stderr, testLogLevel, func() string {
+				return time.Now().UTC().Format("15:04:05.999") + " "
+			})),
 			TransactionalID("p"+randsha()),
 			TransactionTimeout(2*time.Minute),
 			MaxBufferedRecords(10000),