diff --git a/src/SJZY.Track.Api/SJZY.Track.Api.csproj b/src/SJZY.Track.Api/SJZY.Track.Api.csproj
index ff97789d..ccb41380 100644
--- a/src/SJZY.Track.Api/SJZY.Track.Api.csproj
+++ b/src/SJZY.Track.Api/SJZY.Track.Api.csproj
@@ -24,4 +24,7 @@
     <ItemGroup>
         <None Update="kafkalib\**\*" CopyToPublishDirectory="Always" CopyToOutputDirectory="Always" />
     </ItemGroup>
+    <PropertyGroup>
+        <RetainVMGarbageCollection>true</RetainVMGarbageCollection>
+    </PropertyGroup>
 </Project>
diff --git a/src/SJZY.Track.Application/Kafka/WarningCalcServiceExtension.cs b/src/SJZY.Track.Application/Kafka/WarningCalcServiceExtension.cs
index 8d9f2cf7..34666d2b 100644
--- a/src/SJZY.Track.Application/Kafka/WarningCalcServiceExtension.cs
+++ b/src/SJZY.Track.Application/Kafka/WarningCalcServiceExtension.cs
@@ -55,9 +55,10 @@ public static class WarningCalcServiceExtension
                         FetchMinBytes = conf.GetValue<int>("Kafka:Consumer:FetchMinBytes"),
                         FetchMaxBytes = conf.GetValue<int>("Kafka:Consumer:FetchMaxBytes"),
                         FetchWaitMaxMs = conf.GetValue<int>("Kafka:Consumer:FetchWaitMaxMs"),
-                        //日志
-                        Debug = "consumer,cgrp,protocol",
-                        CancellationDelayMaxMs = 100
+                        CancellationDelayMaxMs = 100,
+                        // Debug = "all",
+                        // LogConnectionClose = false,
+                        // LogQueue = true
                     })
                 .SetKeyDeserializer(sp.GetRequiredService<JsonCoreSerializer<TKey>>())
                 .SetValueDeserializer(sp.GetRequiredService<JsonCoreSerializer<TValue>>())
@@ -115,6 +116,9 @@ public static class WarningCalcServiceExtension
                     QueueBufferingMaxKbytes = conf.GetValue<int>("Kafka:Producer:QueueBufferingMaxKbytes"),
                     // 分区器 一致性hash/随机
                     Partitioner = conf.GetValue<Partitioner>("Kafka:Producer:Partitioner"),
+                    // Debug = "all",
+                    // LogConnectionClose = false,
+                    // LogQueue = true
                 })
                 .SetKeySerializer(sp.GetRequiredService<JsonCoreSerializer<TKey>>())
                 .SetValueSerializer(sp.GetRequiredService<JsonCoreSerializer<TValue>>())