anchor.diff:  
   
   t_producer_topic_not_found(Config) when is_list(Config) ->
  +  Client = t_producer_topic_not_found,
     ?assertEqual({error, {not_found, <<"no-such-topic">>}},
  -               brod:produce(?MODULE, <<"no-such-topic">>, 0, <<"k">>, <<"v">>)).
  +               brod:produce(Client, <<"no-such-topic">>, 0, <<"k">>, <<"v">>)).
   
   
   t_producer_partition_not_found(Config) when is_list(Config) ->
  +  Client = t_producer_partition_not_found,
     ?assertEqual({error, {not_found, ?TOPIC, 100}},
  -               brod:produce(?MODULE, ?TOPIC, 100, <<"k">>, <<"v">>)).
  +               brod:produce(Client, ?TOPIC, 100, <<"k">>, <<"v">>)).
   
   %%%_* Help functions ===========================================================
   
  
positive.code:   Pid =
      erlang:spawn(
        fun() ->
          brod:start_link_client(?CLIENT, ?HOSTS, _Config = [], [Producer]),
          receive stop ->
            ok = brod:stop_client(?CLIENT),
            exit(normal)
          end
        end),
    [{producer, Pid} | Config].
  
  end_per_testcase(_Case, Config) ->
    Pid = proplists:get_value(producer, Config),
    try
      Ref = erlang:monitor(process, Pid),
      Pid ! stop,
  
negative.code:                Tester ! {Ref, K, V}
               end,
    ok = brod:consume(ConsumerPid, Callback, -1),
    ok = brod:produce_sync(t_produce_sync, ?TOPIC, Partition, Key, Value),
    receive
      {Ref, K, V} ->
        ok = brod:stop_consumer(ConsumerPid),
  