From ede001183d9efdfb50dd1051aa97cf5a5f876c39 Mon Sep 17 00:00:00 2001
From: s8200g <tomas.naikus@seb.se>
Date: Mon, 16 Dec 2024 18:15:13 +0200
Subject: [PATCH] feat: Exit infinite loop when Exception is thrown.

---
 src/KafkaFlow/Consumers/Consumer.cs | 1 +
 1 file changed, 1 insertion(+)

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
             {