diff --git a/cdc/kv/client.go b/cdc/kv/client.go index 9c169817cc3..423eea05c5d 100644 --- a/cdc/kv/client.go +++ b/cdc/kv/client.go @@ -1027,7 +1027,7 @@ func (s *eventFeedSession) receiveFromStream( }) if err != nil { if status.Code(errors.Cause(err)) == codes.Canceled { - log.Debug( + log.Info( "receive from stream canceled", zap.String("namespace", s.changefeed.Namespace), zap.String("changefeed", s.changefeed.ID),