Skip to content

Commit

Permalink
Turn this to be debug.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Dec 19, 2024
1 parent 54879bd commit dd0fb2c
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion sources/mysql/streaming/dml.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)),
)
Expand Down
2 changes: 1 addition & 1 deletion sources/mysql/streaming/iterator.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)),
)
Expand Down

0 comments on commit dd0fb2c

Please sign in to comment.