From dd0fb2cdd3397200fa9c9d2b77cb5930f6ee24bb Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Wed, 18 Dec 2024 21:25:33 -0800 Subject: [PATCH] Turn this to be debug. --- sources/mysql/streaming/dml.go | 2 +- sources/mysql/streaming/iterator.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sources/mysql/streaming/dml.go b/sources/mysql/streaming/dml.go index f9587f60..76f0d6e7 100644 --- a/sources/mysql/streaming/dml.go +++ b/sources/mysql/streaming/dml.go @@ -20,7 +20,7 @@ func (i *Iterator) processDML(ts time.Time, event *replication.BinlogEvent) ([]l } if !strings.EqualFold(i.cfg.Database, string(rowsEvent.Table.Schema)) { - slog.Info("Skipping this event since the database does not match the configured database", + slog.Debug("Skipping this event since the database does not match the configured database", slog.String("config_db", i.cfg.Database), slog.String("event_db", string(rowsEvent.Table.Schema)), ) diff --git a/sources/mysql/streaming/iterator.go b/sources/mysql/streaming/iterator.go index ba66eceb..e16a922a 100644 --- a/sources/mysql/streaming/iterator.go +++ b/sources/mysql/streaming/iterator.go @@ -231,7 +231,7 @@ func (i *Iterator) persistAndProcessDDL(evt *replication.QueryEvent, ts time.Tim } if !strings.EqualFold(i.cfg.Database, string(evt.Schema)) { - slog.Info("Skipping this event since the database does not match the configured database", + slog.Debug("Skipping this event since the database does not match the configured database", slog.String("config_db", i.cfg.Database), slog.String("event_db", string(evt.Schema)), )