anchor.diff:              {name, Name},
               {takeover, TakeOver}],
       ?log_info("Starting tap stream:~n~p~n", [Args]),
  -    {ok, quiet} = mc_client_binary:tap_connect(Upstream, [{vbuckets, VBuckets},
  -                                                          {checkpoints, Checkpoints},
  -                                                          {name, Name},
  -                                                          {takeover, TakeOver}]),
  +    {ok, quiet} = mc_client_binary:tap_connect(Upstream, Args),
       ok = inet:setopts(Upstream, [{active, once}]),
       ok = inet:setopts(Downstream, [{active, once}]),
   
  
positive.code:                 vbuckets,
                  takeover :: boolean(),
                  takeover_msgs_seen = 0 :: non_neg_integer(),
                  last_seen}).
  
  %% external API
  -export([start_link/3]).
  
negative.code:                                 #state{}.
  process_downstream(<<?RES_MAGIC:8, _/binary>> = Packet,
                     State) ->
      case State#state.dump_file of
          undefined -> ok;
          File -> file:write(File, Packet)
      end,
      ok = gen_tcp:send(State#state.upstream, Packet),
      State.
  
  