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