debug closing exception

stormaref · Apr 17, 2024 · 8bc9c64 · 8bc9c64
1 parent db14e16
commit 8bc9c64
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git 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
@@ -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>();