From 18142818db5684dc0a4e92c041d112bed228b06b Mon Sep 17 00:00:00 2001 From: liangshiwei Date: Tue, 1 Dec 2020 18:27:36 +0800 Subject: [PATCH] Set TaskCreationOptions.LongRunning for Kafka consumers --- .../src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 consumeResult)