anchor.diff:        {ok, NewOffset}
     end.
   
  -get_valid_offset(SocketPid, InitialOffset, Topic, Partition) ->
  +fetch_valid_offset(SocketPid, InitialOffset, Topic, Partition) ->
     Request = #offset_request{ topic = Topic
                              , partition = Partition
                              , time = InitialOffset
  
positive.code:   {ok, State}.
  
  %%%_* Internal Functions =======================================================
  maybe_get_valid_offset(_SocketPid, Offset, Offset, _Topic, _Partition) ->
    {ok, Offset};
  maybe_get_valid_offset(SocketPid, _OldOffset, NewOffset, Topic, Partition) ->
    case get_valid_offset(SocketPid, NewOffset, Topic, Partition) of
      {ok, Offset} ->
        {ok, Offset};
      {error, no_available_offsets} ->
  
negative.code:   Offset1 = proplists:get_value(offset, CbOptions, Offset0),
  
    %% 3. Retrieve valid starting offset
    case fetch_valid_offset(SocketPid, Offset1, Topic, Partition) of
      {error, Error} ->
        {stop, {error, Error}, State0};
      {ok, Offset} ->
  