diff --git a/replication/binlogsyncer.go b/replication/binlogsyncer.go index b27a3cfb9..aed7f2d77 100644 --- a/replication/binlogsyncer.go +++ b/replication/binlogsyncer.go @@ -404,6 +404,8 @@ func (b *BinlogSyncer) prepare() error { return errors.Trace(err) } + b.cfg.Logger.Infof("Connected to %s %s server", b.cfg.Flavor, b.c.GetServerVersion()) + return nil }