anchor.diff:                 Tester ! {Ref, K, V}
                end,
     ok = brod:consume(ConsumerPid, Callback, -1),
  -  ok = brod:produce_sync(?MODULE, ?TOPIC, Partition, Key, Value),
  +  ok = brod:produce_sync(t_produce_sync, ?TOPIC, Partition, Key, Value),
     receive
       {Ref, K, V} ->
         ok = brod:stop_consumer(ConsumerPid),
  
positive.code: -include_lib("eunit/include/eunit.hrl").
  -include_lib("brod/src/brod_int.hrl").
  
  -define(CLIENT, ?MODULE).
  -define(HOSTS, [{"localhost", 9092}]).
  -define(TOPIC, list_to_binary(atom_to_list(?MODULE))).
  
  %%%_* ct callbacks =============================================================
  
  
negative.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 = ?config(producer),
    try
      Ref = erlang:monitor(process, Pid),
      Pid ! stop,
  