diff --git a/spec/lib/waterdrop/producer/transactions_spec.rb b/spec/lib/waterdrop/producer/transactions_spec.rb
index 2c29505..3ba3ed4 100644
--- a/spec/lib/waterdrop/producer/transactions_spec.rb
+++ b/spec/lib/waterdrop/producer/transactions_spec.rb
@@ -291,6 +291,7 @@
         end
 
         producer.transaction do
+          sleep(0.1)
           producer.produce_async(topic: 'example_topic', payload: 'na')
 
           raise(WaterDrop::AbortTransaction)