From 14132f21a1813988e5bff24e04ab10112946d930 Mon Sep 17 00:00:00 2001
From: liangshiwei <liangshiw@outlook.com>
Date: Tue, 1 Dec 2020 20:32:45 +0800
Subject: [PATCH] Use await

---
 .../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 d1589f6409..8ae81a2a26 100644
--- a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs
+++ b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs
@@ -118,7 +118,7 @@ namespace Volo.Abp.Kafka
                     catch (ConsumeException ex)
                     {
                         Logger.LogException(ex, LogLevel.Warning);
-                        AsyncHelper.RunSync(() => ExceptionNotifier.NotifyAsync(ex, logLevel: LogLevel.Warning));
+                        await ExceptionNotifier.NotifyAsync(ex, logLevel: LogLevel.Warning);
                     }
                 }
             }, TaskCreationOptions.LongRunning);