anchor.diff:              Sup2 = start_vbucket_rep_sup(Rep),
               ?xdcr_debug("bucket gone or never existed, shut down current vb rep "
                           "supervisor: ~p and create a new one :~p", [Sup, Sup2]),
  -            NewState = State#replication{vbucket_sup = Sup2};
  +            {noreply, State#replication{vbucket_sup = Sup2}};
           SrcConfig ->
               NewVbs = xdc_rep_utils:my_active_vbuckets(SrcConfig),
               NewState =
  
positive.code:                                     num_tokens = MaxConcurrentReps,
                                      init_throttle = InitThrottle,
                                      work_throttle = WorkThrottle,
                                      vbucket_sup = Sup}
      end,
      {ok, RepState}.
  
  handle_call(stats, _From, #replication{vb_rep_dict = Dict,
                                         rep = Rep,
  
negative.code:                                      init_throttle = InitThrottle,
                                       work_throttle = WorkThrottle,
                                       vbucket_sup = Sup},
              {ok, start_vb_replicators(RepState0)};
          Error ->
              ?xdcr_error("fail to fetch a valid bucket config and no vb replicator "
                          "would be created (error: ~p)", [Error]),
  