From 9f49b111cc4e56f38785b75d983046516af38304 Mon Sep 17 00:00:00 2001 From: liangshiwei Date: Mon, 8 Feb 2021 09:45:42 +0800 Subject: [PATCH] Update KafkaMessageConsumer --- .../src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs | 1 + 1 file changed, 1 insertion(+) 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 2ff70dd8d5..3b8f022012 100644 --- a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs +++ b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs @@ -1,5 +1,6 @@ using System; using System.Collections.Concurrent; +using System.Linq; using System.Threading.Tasks; using Confluent.Kafka; using Confluent.Kafka.Admin;