From 8bc9c647bec3e570b96f7f508c4cb09e35b0926b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E2=80=9CAref?= <storm.aref@gmail.com>
Date: Wed, 17 Apr 2024 18:54:53 +0330
Subject: [PATCH] debug closing exception

---
 KafkaStorm/KafkaStorm.csproj                 | 2 +-
 KafkaStorm/Services/ConsumerHostedService.cs | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/KafkaStorm/KafkaStorm.csproj b/KafkaStorm/KafkaStorm.csproj
index fceabcc..a38ffbf 100644
--- a/KafkaStorm/KafkaStorm.csproj
+++ b/KafkaStorm/KafkaStorm.csproj
@@ -5,7 +5,7 @@
         <Nullable>enable</Nullable>
         <LangVersion>latest</LangVersion>
         <Authors>ArefAzizian</Authors>
-        <Version>8.0.3</Version>
+        <Version>8.0.4</Version>
         <PackageId>KafKaStorm</PackageId>
         <LangVersion>latest</LangVersion>
         <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
diff --git a/KafkaStorm/Services/ConsumerHostedService.cs b/KafkaStorm/Services/ConsumerHostedService.cs
index de0362e..df15c06 100644
--- a/KafkaStorm/Services/ConsumerHostedService.cs
+++ b/KafkaStorm/Services/ConsumerHostedService.cs
@@ -49,6 +49,7 @@ public Task StartAsync(CancellationToken cancellationToken)
 
     private void Handle(CancellationToken cancellationToken)
     {
+        if (cancellationToken.IsCancellationRequested) return;
         var result = _consumer.Consume(1);
         var message = JsonSerializer.Deserialize<TMessage>(result.Message.Value) ??
                       throw new MessageNullException<TMessage>();