diff --git a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs
index c22ca6756b..d1589f6409 100644
--- a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs
+++ b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs
@@ -121,7 +121,7 @@ namespace Volo.Abp.Kafka
                         AsyncHelper.RunSync(() => ExceptionNotifier.NotifyAsync(ex, logLevel: LogLevel.Warning));
                     }
                 }
-            });
+            }, TaskCreationOptions.LongRunning);
         }
 
         protected virtual async Task HandleIncomingMessage(ConsumeResult<string, byte[]> consumeResult)