diff --git a/test/integration/aws/infra-dependent/msk.test.js b/test/integration/aws/infra-dependent/msk.test.js
index 8d73b5d07..3f31b8ef2 100644
--- a/test/integration/aws/infra-dependent/msk.test.js
+++ b/test/integration/aws/infra-dependent/msk.test.js
@@ -86,7 +86,10 @@ describe('AWS - MSK Integration Test', function () {
           FunctionName: `${stackName}-producer`,
           InvocationType: 'RequestResponse',
         }),
-      { timeout: 120 * 1000 }
+      {
+        checkIsComplete: (soFarEvents) =>
+          soFarEvents.reduce((data, event) => data + event.message, '').includes(message),
+      }
     );
 
     const logs = events.reduce((data, event) => data + event.message, '');