From 5e43bf37f8e955cbe72a7fd526f10d91c3a0da51 Mon Sep 17 00:00:00 2001
From: hardstylewyl <827778732@qq.com>
Date: Wed, 11 Jun 2025 11:00:02 +0800
Subject: [PATCH] =?UTF-8?q?perf:GC=E8=B0=83=E4=BC=98System.GC.RetainVM:tru?=
 =?UTF-8?q?e=EF=BC=8C=E5=85=B3=E9=97=ADlibrdkafka=E7=9A=84=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=EF=BC=8C=E4=BB=A5=E5=87=8F=E5=B0=91=E5=86=85=E5=AD=98?=
 =?UTF-8?q?=E5=8D=A0=E7=94=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/SJZY.Track.Api/SJZY.Track.Api.csproj               |  3 +++
 .../Kafka/WarningCalcServiceExtension.cs               | 10 +++++++---
 2 files changed, 10 insertions(+), 3 deletions(-)

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>>())