diff --git a/.gitignore b/.gitignore
index 0e32ff0..4472a76 100644
--- a/.gitignore
+++ b/.gitignore
@@ -90,3 +90,4 @@
 /MyFaster
 /MyFunctioncache
 /mypwsh
+/Redis定阅/obj
diff --git a/BLWLogServer/BLWLogServer.csproj.user b/BLWLogServer/BLWLogServer.csproj.user
index 4418a07..2add57c 100644
--- a/BLWLogServer/BLWLogServer.csproj.user
+++ b/BLWLogServer/BLWLogServer.csproj.user
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="utf-8"?>
 <Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
   <PropertyGroup>
-    <NameOfLastUsedPublishProfile>E:\tian\chongxin\NewGit\Web_BLSKafka_Server_Prod\BLWLogServer\Properties\PublishProfiles\FolderProfile.pubxml</NameOfLastUsedPublishProfile>
+    <NameOfLastUsedPublishProfile>FolderProfile</NameOfLastUsedPublishProfile>
     <Controller_SelectedScaffolderID>ApiControllerEmptyScaffolder</Controller_SelectedScaffolderID>
     <Controller_SelectedScaffolderCategoryPath>root/Common/Api</Controller_SelectedScaffolderCategoryPath>
   </PropertyGroup>
diff --git a/BLWLogServer/Services/KafkaConsume.cs b/BLWLogServer/Services/KafkaConsume.cs
index 15cd3ac..c161750 100644
--- a/BLWLogServer/Services/KafkaConsume.cs
+++ b/BLWLogServer/Services/KafkaConsume.cs
@@ -30,16 +30,13 @@ namespace BLWLogServer.Services
 
         protected async override Task ExecuteAsync(CancellationToken stoppingToken)
         {
-            await Task.Factory.StartNew(async () =>
+            var consumers = new List<Task>();
+            for (int i = 0; i < 3; i++)
             {
-                var consumers = new List<Task>();
-                for (int i = 0; i < 3; i++)
-                {
-                    consumers.Add(Task.Run(() => StartConsumer(stoppingToken)));
-                }
-                await Task.WhenAll(consumers);
-                //await StartConsumer(stoppingToken);
-            }, TaskCreationOptions.LongRunning);
+                consumers.Add(StartConsumer(stoppingToken));
+            }
+            await Task.WhenAll(consumers);
+            //await StartConsumer(stoppingToken);
         }
         private async Task StartConsumer(CancellationToken stoppingToken)
         {