diff --git a/Sources/Kafka/KafkaConsumer.swift b/Sources/Kafka/KafkaConsumer.swift
index 52a8d49d..bb88ffd2 100644
--- a/Sources/Kafka/KafkaConsumer.swift
+++ b/Sources/Kafka/KafkaConsumer.swift
@@ -467,9 +467,10 @@ public final class KafkaConsumer: Sendable, Service {
                 result = .failure(error)
             }
 
-            if let result {
-                messageResults.append(result)
+            guard let result else {
+                return messageResults
             }
+            messageResults.append(result)
         }
 
         return messageResults