From 44f397b746a37627545c4a7cf366bfb5c52be29f Mon Sep 17 00:00:00 2001
From: Seungjin Kim <seungjin.kim@stord.com>
Date: Tue, 24 Sep 2024 11:07:26 -0700
Subject: [PATCH] UPDATE: make test less flaky

---
 test/kafee/producer/async_adapter_test.exs | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

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