anchor.diff:        {error, Reason}
     end.
   
  --spec find_consumer(client(), topic(), partition()) ->
  +-spec find_consumer(brod:client(), brod:topic(), brod:partition()) ->
           {ok, pid()} | {error, get_consumer_error()}.
   find_consumer(Client, Topic, Partition) ->
     case safe_gen_call(Client, get_consumers_sup_pid, infinity) of
  
positive.code:   end.
  
  
  -spec maybe_connect(#state{}, hostname(), portnum(), Reason) ->
          {#state{}, Result} when
            Reason :: not_found | dead_socket(),
            Result :: {ok, pid()} | {error, any()}.
  
negative.code:   end.
  
  %% @doc Stop all partition consumers of the given topic.
  -spec stop_consumer(brod:client(), brod:topic()) -> ok | {error, any()}.
  stop_consumer(Client, TopicName) ->
    safe_gen_call(Client, {stop_consumer, TopicName}, infinity).
  
  