ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:修复预警计算记录链路逻辑错误

Browse Source
This commit is contained in:
hardstylewyl 2025-06-19 15:59:03 +08:00
parent fee0768853
commit 3d162cf997
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/SJZY.Track.Application/Kafka/WarningCalcBackgroundService.cs
View File

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