diff --git a/spec/lib/waterdrop/instrumentation/notifications_spec.rb b/spec/lib/waterdrop/instrumentation/notifications_spec.rb
index 74d63b22..ff51987c 100644
--- a/spec/lib/waterdrop/instrumentation/notifications_spec.rb
+++ b/spec/lib/waterdrop/instrumentation/notifications_spec.rb
@@ -66,6 +66,8 @@ def on_message_produced_async(_event)
       ]
     end
 
+    after { producer.close }
+
     context 'when producer is initialized' do
       it { expect(status.to_s).to eq('initial') }
       it { expect(events).to be_empty }