anchor.diff:  store_topic_buffer(Topic, LeaderBuffer, TopicBuffer) ->
     lists:keystore(Topic, 1, LeaderBuffer, {Topic, TopicBuffer}).
   
  +do_debug(Pid, Debug) ->
  +  {ok, Sockets} = get_sockets(Pid),
  +  lists:foreach(
  +    fun(#socket{pid = SocketPid}) ->
  +        {ok, _} = gen:call(SocketPid, system, {debug, Debug})
  +    end, Sockets),
  +  {ok, _} = gen:call(Pid, system, {debug, Debug}),
  +  ok.
  +
   %% Tests -----------------------------------------------------------------------
   -ifdef(TEST).
   
  
positive.code: 
  code_change(_OldVsn, State, _Extra) ->
    {ok, State}.
  
  %%%_* Internal functions -------------------------------------------------------
  handle_produce(From, Topic, Partition, Key, Value, State0) ->
  
negative.code:         , handle_info/2
          , terminate/2
          , code_change/3
          , format_status/2
          ]).
  
  %%%_* Includes -----------------------------------------------------------------
  