From 7f11e5b3a19aebb80cf10c11404dc02867693091 Mon Sep 17 00:00:00 2001 From: liangshiwei Date: Mon, 4 Oct 2021 17:36:01 +0800 Subject: [PATCH] Update IKafkaMessageConsumerFactory --- .../Volo/Abp/Kafka/IKafkaMessageConsumerFactory.cs | 2 -- .../Volo/Abp/Kafka/KafkaMessageConsumerFactory.cs | 2 -- 2 files changed, 4 deletions(-) diff --git a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/IKafkaMessageConsumerFactory.cs b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/IKafkaMessageConsumerFactory.cs index 96ec753dc2..2b01b5a935 100644 --- a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/IKafkaMessageConsumerFactory.cs +++ b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/IKafkaMessageConsumerFactory.cs @@ -8,13 +8,11 @@ /// not disposed until end of the application. /// /// - /// /// /// /// IKafkaMessageConsumer Create( string topicName, - string deadLetterTopicName, string groupId, string connectionName = null); } diff --git a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumerFactory.cs b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumerFactory.cs index 68d1162b7f..9d199b15f9 100644 --- a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumerFactory.cs +++ b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumerFactory.cs @@ -1,5 +1,4 @@ using System; -using System.Threading.Tasks; using Microsoft.Extensions.DependencyInjection; using Volo.Abp.DependencyInjection; @@ -16,7 +15,6 @@ namespace Volo.Abp.Kafka public IKafkaMessageConsumer Create( string topicName, - string deadLetterTopicName, string groupId, string connectionName = null) {