diff --git a/instrumentation/racecar/test/opentelemetry/instrumentation/racecar/patches/runner_test.rb b/instrumentation/racecar/test/opentelemetry/instrumentation/racecar/patches/runner_test.rb
index c2413ae87f..9e0703d245 100644
--- a/instrumentation/racecar/test/opentelemetry/instrumentation/racecar/patches/runner_test.rb
+++ b/instrumentation/racecar/test/opentelemetry/instrumentation/racecar/patches/runner_test.rb
@@ -83,11 +83,12 @@ def self.messages_seen
           end
 
           def process(message)
-            TestConsumer.messages_seen << message
-            produce(
+            producea
               'message seen',
               topic: "ack-#{message.topic}"
             )
+            deliver!
+            TestConsumer.messages_seen << message
           end
         end
         TestConsumer.subscribes_to(topic_name)
@@ -229,6 +230,7 @@ def process_batch(messages)
               'message seen',
               topic: "ack-#{message.topic}"
             )
+            deliver!
             TestBatchConsumer.messages_seen << message
           end
         end