anchor.diff:         _Offset0 = SendFun(1),
          Offset1 = SendFun(2),
          Offset2 = SendFun(3),
  -       %% Start as if committed Offset1, expect it to start fetching from Offset2
  +       %% Start as if committed Offset1, expect it to start fetching from
  +       %% Offset2
          InitArgs = {_IsAsyncAck = true,
                      _ConsumerOffsets = [{0, Offset1}]},
          {ok, SubscriberPid} =
  
positive.code:                    , {max_wait_time, 1000}
                     , {partition_restart_delay_seconds, 1}
                     ],
    InitArgs = {_IsAsyncAck = true, _CommittedOffsets = []},
    Partition = 0,
    SendFun =
      fun(I) ->
  
negative.code:                    , {sleep_timeout, 0}
                     , {max_wait_time, 1000}
                     ],
    ?check_trace(
       %% Run stage:
       begin
         O0 = produce({?topic, 0}, <<0>>),
         InitArgs = {true, [{0, O0}]},
         {ok, SubscriberPid} =
           brod:start_link_topic_subscriber(?CLIENT_ID, ?topic, ConsumerConfig,
                                            ?MODULE, InitArgs),
         %% Send messages:
         Messages = [<<I>> || I <- lists:seq(1, MaxSeqNo)],
         [produce({?topic, 0}, I) || I <- Messages],
         %% Ack messages:
         wait_and_ack(SubscriberPid, Messages),
         ok = brod_topic_subscriber:stop(SubscriberPid),
         Messages
       end,
       %% Check stage:
       fun(Expected, Trace) ->
  