Skip to content

Commit c1b700c

Browse files
serprexdveeden
andauthored
Update replication/binlogsyncer.go
Co-authored-by: Daniël van Eeden <[email protected]>
1 parent a9b1ebc commit c1b700c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

replication/binlogsyncer.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -862,7 +862,7 @@ func (b *BinlogSyncer) handleEventAndACK(s *BinlogStreamer, e *BinlogEvent, need
862862
case *RotateEvent:
863863
b.nextPos.Name = string(event.NextLogName)
864864
b.nextPos.Pos = uint32(event.Position)
865-
b.cfg.Logger.Info(fmt.Sprintf("rotate to %s", b.nextPos))
865+
b.cfg.Logger.Info("rotate to next binlog", slog.String("file", b.nextPos.Name), slog.Int("position", b.nextPos))
866866

867867
case *GTIDEvent:
868868
if b.prevGset == nil {

0 commit comments

Comments
 (0)