anchor.diff:  ensure_integer_offset_time(T) when is_integer(T) -> T.
   
   -spec do_find_leader_in_metadata(kpro_MetadataResponse(),
  -                                 topic(), partition()) -> endpoint().
  +                                 brod:topic(), brod:partition()) -> brod:endpoint().
   do_find_leader_in_metadata(Metadata, Topic, Partition) ->
     #kpro_MetadataResponse{ broker_L        = Brokers
                           , topicMetadata_L = [TopicMetadata]
  
positive.code: %% @doc Find leader broker ID for the given topic-partiton in
  %% the metadata response received from socket.
  %% @end
  -spec find_leader_in_metadata(kpro_MetadataResponse(), topic(), partition()) ->
          {ok, endpoint()} | {error, any()}.
  find_leader_in_metadata(Metadata, Topic, Partition) ->
    try
      {ok, do_find_leader_in_metadata(Metadata, Topic, Partition)}
  
negative.code: %% are semantic 'offset', this is why often a variable named
  %% Offset is used as the Time argument.
  %% @end
  -spec offset_request(brod:topic(), brod:partition(),
                       brod:offset_time(), pos_integer()) -> kpro_OffsetRequest().
  offset_request(Topic, Partition, TimeOrSemanticOffset, MaxOffsets) ->
    Time = ensure_integer_offset_time(TimeOrSemanticOffset),
    kpro:offset_request(Topic, Partition, Time, MaxOffsets).
  