diff --git a/test/kafee/producer/async_adapter_test.exs b/test/kafee/producer/async_adapter_test.exs
index fa318ed..5d290e4 100644
--- a/test/kafee/producer/async_adapter_test.exs
+++ b/test/kafee/producer/async_adapter_test.exs
@@ -128,9 +128,7 @@ defmodule Kafee.Producer.AsyncAdapterTest do
 
       # clean up because kafka in test only has one partition, so errors happen
       capture_log(fn ->
-        for pid <- worker_pids do
-          GenServer.stop(pid)
-        end
+        stop_supervised(MyProducer)
       end)
     end
   end