Set TaskCreationOptions.LongRunning for Kafka consumers

6 years ago · 18142818db
1 changed files with 1 additions and 1 deletions
--- 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)