anchor.diff:          , t_2_members_subscribe_to_different_topics/1
           , t_async_commit/1
           , t_consumer_crash/1
  +        , t_assign_partitions_handles_updating_state/1
           ]).
   
   
  
positive.code:                    ],
    CaseRef = t_consumer_crash,
    CasePid = self(),
    InitArgs = {CaseRef, CasePid, _IsAsyncAck = true, _IsAsyncCommit = false},
    Partition = 0,
    {ok, SubscriberPid} =
      brod:start_link_group_subscriber(?CLIENT_ID, ?GROUP_ID, [?TOPIC1],
  
negative.code:   CaseRef = t_async_commit,
    CasePid = self(),
    Partition = 0,
    InitArgs = {CaseRef, CasePid, _IsAsyncAck = false, _IsAsyncCommit = true, _IsAssignPartitions = false},
    %% use a one-time gid for clean test
    GroupId = list_to_binary("one-time-gid-" ++ integer_to_list(rand:uniform(1000000000))),
    StartSubscriber =
  