anchor.diff:  %% @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()}.
  +-spec find_leader_in_metadata(kpro_MetadataResponse(),
  +                              brod:topic(),
  +                              brod:partition()) ->
  +                                     {ok, brod:endpoint()} | {error, any()}.
   find_leader_in_metadata(Metadata, Topic, Partition) ->
     try
       {ok, do_find_leader_in_metadata(Metadata, Topic, Partition)}
  
positive.code: 
  -define(IS_BYTE(I), (I>=0 andalso I<256)).
  
  -spec bytes(key() | value() | kv_list()) -> non_neg_integer().
  bytes([]) -> 0;
  bytes(undefined) -> 0;
  bytes(I) when ?IS_BYTE(I) -> 1;
  
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).
  