anchor.diff:  %% @equiv produce(Pid, Topic, 0, <<>>, Value)
   -spec produce(pid(), binary(), binary()) -> ok | {error, any()}.
   produce(Pid, Topic, Value) ->
  -  produce(Pid, Topic, 0, <<>>, Value).
  +  produce(Pid, Topic, 0, Value).
  +
  +%% @equiv produce(Pid, Topic, Partition, <<>>, Value)
  +-spec produce(pid(), binary(), integer(), binary()) -> ok | {error, any()}.
  +produce(Pid, Topic, Partition, Value) ->
  +  produce(Pid, Topic, Partition, <<>>, Value).
   
   %% @doc Send message to a broker.
   %%      Internally it's a gen_server:call to brod_srv process. Returns
  
positive.code: %%%_* Types --------------------------------------------------------------------
  
  %%%_* API ----------------------------------------------------------------------
  %% @doc Open connection to kafka broker
  %%      Hosts: list of "bootstrap" kafka nodes, {"hostname", 1234}
  %%      RequiredAcks: how many kafka nodes must acknowledge a message
  %%      before sending a response
  
negative.code: -export([ connect/3
          , close_connection/1
          , produce/3
          , produce/4
          , produce/5
          ]).
  
  