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