diff --git a/src/KafkaFlow/Consumers/Consumer.cs b/src/KafkaFlow/Consumers/Consumer.cs
index 77f74e07b..385dba538 100644
--- a/src/KafkaFlow/Consumers/Consumer.cs
+++ b/src/KafkaFlow/Consumers/Consumer.cs
@@ -205,6 +205,7 @@ public async ValueTask<ConsumeResult<byte[], byte[]>> ConsumeAsync(CancellationT
             catch (Exception ex)
             {
                 _logHandler.Error("Kafka Consumer Error", ex, null);
+                throw;
             }
             finally
             {