diff --git a/packages/microservices/server/server-kafka.ts b/packages/microservices/server/server-kafka.ts
index e9878ae19..8bd6a7cfb 100644
--- a/packages/microservices/server/server-kafka.ts
+++ b/packages/microservices/server/server-kafka.ts
@@ -218,9 +218,10 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
           if (err instanceof KafkaRetriableException && !isPromiseResolved) {
             isPromiseResolved = true;
             reject(err);
+          } else {
+            resolve()
           }
           replayStream$.error(err);
-          resolve();
         },
         complete: () => replayStream$.complete(),
       });