Ensure TestParititioner to make consumer_group_implementation_test mo…

…re reliable
kafkaex · Aug 12, 2020 · 2ae170d · 2ae170d
1 parent 7461e45
commit 2ae170d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/test/integration/consumer_group_implementation_test.exs b/test/integration/consumer_group_implementation_test.exs
@@ -132,7 +132,7 @@ defmodule KafkaEx.ConsumerGroupImplementationTest do
 
   setup do
     ports_before = num_open_ports()
-    {:ok, _} = TestPartitioner.start_link()
+    {:ok, test_partitioner_pid} = TestPartitioner.start_link()
 
     {:ok, consumer_group_pid1} =
       ConsumerGroup.start_link(
@@ -163,6 +163,7 @@ defmodule KafkaEx.ConsumerGroupImplementationTest do
     on_exit(fn ->
       sync_stop(consumer_group_pid1)
       sync_stop(consumer_group_pid2)
+      sync_stop(test_partitioner_pid)
     end)
 
     {