From b167dbde9f27dddc6d4f6797f6129d05b1908cbf Mon Sep 17 00:00:00 2001 From: yangxiaodong Date: Fri, 21 Jul 2017 15:21:31 +0800 Subject: [PATCH] fix error name. --- src/DotNetCore.CAP.Kafka/CAP.Options.Extensions.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/DotNetCore.CAP.Kafka/CAP.Options.Extensions.cs b/src/DotNetCore.CAP.Kafka/CAP.Options.Extensions.cs index 65314f4..fa6dd2b 100644 --- a/src/DotNetCore.CAP.Kafka/CAP.Options.Extensions.cs +++ b/src/DotNetCore.CAP.Kafka/CAP.Options.Extensions.cs @@ -8,13 +8,13 @@ namespace Microsoft.Extensions.DependencyInjection { public static CapOptions UseKafka(this CapOptions options, string bootstrapServers) { - return options.UseRabbitMQ(opt => + return options.UseKafka(opt => { opt.Servers = bootstrapServers; }); } - public static CapOptions UseRabbitMQ(this CapOptions options, Action configure) + public static CapOptions UseKafka(this CapOptions options, Action configure) { if (configure == null) throw new ArgumentNullException(nameof(configure));