feat: Exit infinite loop when Exception is thrown.

s8200g · brmagadutra · commit ede001183d9e · 2025-04-07T08:16:08.000+01:00
diff --git 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
             {

Original file line number	Diff line number	Diff line change
`@@ -205,6 +205,7 @@ public async ValueTask<ConsumeResult<byte[], byte[]>> ConsumeAsync(CancellationT`
`205`	`205`	`catch (Exception ex)`
`206`	`206`	`{`
`207`	`207`	`_logHandler.Error("Kafka Consumer Error", ex, null);`
	`208`	`+ throw;`
`208`	`209`	`}`
`209`	`210`	`finally`
`210`	`211`	`{`