debug

stormaref · Apr 17, 2024 · 5a5ecfc · 5a5ecfc
1 parent 61e9c93
commit 5a5ecfc
Show file tree

Hide file tree

Showing 2 changed files with 4 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.5</Version>
+        <Version>8.0.6</Version>
         <PackageId>KafKaStorm</PackageId>
         <LangVersion>latest</LangVersion>
         <GeneratePackageOnBuild>true</GeneratePackageOnBuild>

diff --git a/KafkaStorm/Services/ConsumerHostedService.cs b/KafkaStorm/Services/ConsumerHostedService.cs
@@ -51,6 +51,9 @@ private void Handle(CancellationToken cancellationToken)
     {
         if (cancellationToken.IsCancellationRequested) return;
         var result = _consumer.Consume(ConsumerRegistrationFactory.ConsumingPeriod);
+        if (result == null)
+            return;
+
         var message = JsonSerializer.Deserialize<TMessage>(result.Message.Value) ??
                       throw new MessageNullException<TMessage>();
         _myConsumer.Handle(message, cancellationToken);