anchor.diff:      false ->
         {ok, Messages}
     end.
  -
  -console_consumer(Hosts, Topic, Partition, Offset) ->
  -  simple_consumer(Hosts, Topic, Partition, Offset, user).
  -
  -file_consumer(Hosts, Topic, Partition, Offset, Filename) ->
  -  {ok, File} = file:open(Filename, [write, append]),
  -  C = simple_consumer(Hosts, Topic, Partition, Offset, File),
  -  MonitorFun = fun() ->
  -                   Mref = erlang:monitor(process, C),
  -                   receive
  -                     {'DOWN', Mref, process, C, _} ->
  -                       io:format("~nClosing ~s~n", [Filename]),
  -                       file:close(File)
  -                   end
  -               end,
  -  proc_lib:spawn(fun() -> MonitorFun() end),
  -  C.
  -
  -simple_consumer(Hosts, Topic, Partition, Offset, Io) ->
  -  {ok, C} = brod:start_link_consumer(Hosts, Topic, Partition),
  -  Pid = proc_lib:spawn_link(fun() -> simple_consumer_loop(C, Io) end),
  -  Callback = fun(MsgOffset, K, V) -> print_message(Io, MsgOffset, K, V) end,
  -  ok = brod:consume(C, Callback, Offset),
  -  Pid.
   
   %% escript entry point
   main([]) ->
  
positive.code:         , get_offsets/5
          , fetch/4
          , fetch/7
          , console_consumer/4
          , file_consumer/5
          , simple_consumer/5
          ]).
  
  %% escript
  
negative.code:                               },
    brod_producer:sync_produce_request(Expect).
  
  %% @doc Fetch broker metadata
  -spec get_metadata([endpoint()]) -> {ok, #metadata_response{}} | {error, any()}.
  get_metadata(Hosts) ->
  