Add testcase

kafka4beam · Jun 16, 2020 · 7be53da · 7be53da
1 parent 8853e38
commit 7be53da
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/test/brod_group_subscriber_SUITE.erl b/test/brod_group_subscriber_SUITE.erl
@@ -471,7 +471,15 @@ t_async_commit(Config) when is_list(Config) ->
          %% had been committed:
          ?assertMatch( []
                      , ?projection(value, handled_messages(AfterRestart2))
-                     )
+                     ),
+         %% Check that terminate callback was called on each restart
+         %% (for the new behavior):
+         Behavior =:= brod_group_subscriber orelse
+           ?assertMatch( [ #{topic := Topic, partition := Partition}
+                         , #{topic := Topic, partition := Partition}
+                         ]
+                       , ?of_kind(brod_test_group_subscriber_terminate, Trace)
+                       )
      end).
 
 t_assign_partitions_handles_updating_state(Config) when is_list(Config) ->