anchor.diff:  get_metadata(Hosts, Topics) ->
     brod_utils:get_metadata(Hosts, Topics).
   
  +%% @equiv get_offsets(Hosts, Topic, Partition, -2, 1)
  +get_offsets(Hosts, Topic, Partition) ->
  +  get_offsets(Hosts, Topic, Partition, -2, 1).
  +
   get_offsets(Hosts, Topic, Partition, Time, MaxNOffsets) ->
     {ok, Pid} = connect_leader(Hosts, Topic, Partition),
     Request = #offset_request{ topic = Topic
  
positive.code: stop_consumer(Pid) ->
    brod_consumer:stop(Pid).
  
  %% @doc Start consuming message from a partition.
  %% Subscriber: a process which will receive messages
  %% Offset: Where to start to fetch data from.
  
negative.code: %% Consumer API
  -export([ start_consumer/3
          , stop_consumer/1
          , consume/2
          , consume/6
          ]).
  
  %% Management and testing API
  -export([ get_metadata/1
          , get_metadata/2
          , get_offsets/3
          , get_offsets/5
          , fetch/7
          ]).
  