Add DB to Logger.

artie-labs · Mar 22, 2024 · 8fe4f97 · 8fe4f97
1 parent 7ac7dfb
commit 8fe4f97
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sources/mysql/snapshot.go b/sources/mysql/snapshot.go
@@ -47,7 +47,7 @@ func (s *Source) Run(ctx context.Context, writer kafkalib.BatchWriter) error {
 }
 
 func (s Source) snapshotTable(ctx context.Context, writer kafkalib.BatchWriter, tableCfg config.MySQLTable) error {
-	logger := slog.With(slog.String("table", tableCfg.Name))
+	logger := slog.With(slog.String("table", tableCfg.Name), slog.String("database", s.cfg.Database))
 	snapshotStartTime := time.Now()
 
 	adapter, err := adapter.NewMySQLAdapter(s.db, s.cfg.Database, tableCfg)