diff --git a/KafkaStorm/KafkaStorm.csproj b/KafkaStorm/KafkaStorm.csproj
index cf771e7..9ca9859 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.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
index 361c52e..02d1ce1 100644
--- 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);