anchor.diff:  %% default value -1 (latest) is used.
   %
   % commented out as it's an optional callback
  -%-callback get_committed_offsets(group_id(), [{topic(), partition()}],
  +%-callback get_committed_offsets(brod:group_id(), [{brod:topic(), brod:partition()}],
   %                                cb_state()) ->
  -%            {ok, [{{topic(), partition()}, offset()}], cb_state()}.
  +%            {ok, [{{brod:topic(), brod:partition()}, brod:offset()}], cb_state()}.
   
   
   %% This function is called only when 'partition_assignment_strategy' is
  
positive.code: %%   The term() that is going to be passed to CbModule:init/1 when
  %%   initializing the subscriger.
  %% @end
  -spec start_link(client(), group_id(), [topic()],
                   group_config(), consumer_config(), module(), term()) ->
                      {ok, pid()} | {error, any()}.
  start_link(Client, GroupId, Topics, GroupConfig,
             ConsumerConfig, CbModule, CbInitArg) ->
  
negative.code: -type cb_state() :: term().
  
  %% Initialize the callback module s state.
  -callback init(brod:group_id(), term()) -> {ok, cb_state()}.
  
  %% Handle a message. Return one of:
  %%
  