anchor.diff:  -define(DEFAULT_ACK_TIMEOUT,  1000). % default broker ack timeout
   
   %%%_* API ----------------------------------------------------------------------
  +%% @deprecated
  +%% @equiv start_link_producer(Hosts)
  +-spec start_producer([host()]) -> {ok, pid()} | {error, any()}.
  +start_producer(Hosts) ->
  +  start_link_producer(Hosts).
  +
  +%% @deprecated
  +%% @equiv start_link_producer(Hosts, RequiredAcks, AckTimeout)
  +-spec start_producer([host()], integer(), integer()) ->
  +                   {ok, pid()} | {error, any()}.
  +start_producer(Hosts, RequiredAcks, AckTimeout) ->
  +  start_link_producer(Hosts, RequiredAcks, AckTimeout).
  +
   %% @equiv start_link_producer(Hosts, 1, 1000)
   -spec start_link_producer([host()]) -> {ok, pid()} | {error, any()}.
   start_link_producer(Hosts) ->
  
positive.code:       ok
    end.
  
  %% @doc Start consumer process
  -spec start_link_consumer([host()], binary(), integer()) ->
                          {ok, pid()} | {error, any()}.
  
negative.code: 
  %% Consumer API
  -export([ start_link_consumer/3
          , start_consumer/3
          , stop_consumer/1
          , consume/2
          , consume/6
  