From 3d162cf99744eaadea33f23f6997b34aa7065068 Mon Sep 17 00:00:00 2001
From: hardstylewyl <827778732@qq.com>
Date: Thu, 19 Jun 2025 15:59:03 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8D=E9=A2=84=E8=AD=A6?=
 =?UTF-8?q?=E8=AE=A1=E7=AE=97=E8=AE=B0=E5=BD=95=E9=93=BE=E8=B7=AF=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Kafka/WarningCalcBackgroundService.cs                      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/SJZY.Track.Application/Kafka/WarningCalcBackgroundService.cs b/src/SJZY.Track.Application/Kafka/WarningCalcBackgroundService.cs
index 9aaaff06..32a75ddc 100644
--- a/src/SJZY.Track.Application/Kafka/WarningCalcBackgroundService.cs
+++ b/src/SJZY.Track.Application/Kafka/WarningCalcBackgroundService.cs
@@ -70,6 +70,7 @@ public sealed class WarningCalcBackgroundService : BackgroundService
         {
             _activity?.SetTag("HandleTime", _stopwatch.ElapsedMilliseconds);
             _activity?.Dispose();
+            _activity = null;
         }
     }
 
@@ -97,8 +98,6 @@ public sealed class WarningCalcBackgroundService : BackgroundService
 
         // 提交内存中所有的偏移到服务器，适用于EnableAutoCommit为false的手动提交场景
         _consumer.Commit();
-        _activity.Dispose();
-        _activity = null;
     }
 
     private async ValueTask MessageHandler(IEnumerable<Message<WarningSignalKey, WarningSignal>> messages, CancellationToken ct)