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

Merge branch 'S07' into test

Browse Source
This commit is contained in:
hardstylewyl 2025-06-12 10:21:31 +08:00
commit 4f5a9c2eb7
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/SJZY.Track.Api/SJZY.Track.Api.csproj
View File

@ -24,4 +24,7 @@
<ItemGroup> <ItemGroup>
<None Update="kafkalib\**\*" CopyToPublishDirectory="Always" CopyToOutputDirectory="Always" /> <None Update="kafkalib\**\*" CopyToPublishDirectory="Always" CopyToOutputDirectory="Always" />
</ItemGroup> </ItemGroup>
<PropertyGroup>
<RetainVMGarbageCollection>true</RetainVMGarbageCollection>
</PropertyGroup>
</Project> </Project>

10
src/SJZY.Track.Application/Kafka/WarningCalcServiceExtension.cs
View File

@ -55,9 +55,10 @@ public static class WarningCalcServiceExtension
FetchMinBytes = conf.GetValue<int>("Kafka:Consumer:FetchMinBytes"), FetchMinBytes = conf.GetValue<int>("Kafka:Consumer:FetchMinBytes"),
FetchMaxBytes = conf.GetValue<int>("Kafka:Consumer:FetchMaxBytes"), FetchMaxBytes = conf.GetValue<int>("Kafka:Consumer:FetchMaxBytes"),
FetchWaitMaxMs = conf.GetValue<int>("Kafka:Consumer:FetchWaitMaxMs"), FetchWaitMaxMs = conf.GetValue<int>("Kafka:Consumer:FetchWaitMaxMs"),
//日志 CancellationDelayMaxMs = 100,
Debug = "consumer,cgrp,protocol", // Debug = "all",
CancellationDelayMaxMs = 100 // LogConnectionClose = false,
// LogQueue = true
}) })
.SetKeyDeserializer(sp.GetRequiredService<JsonCoreSerializer<TKey>>()) .SetKeyDeserializer(sp.GetRequiredService<JsonCoreSerializer<TKey>>())
.SetValueDeserializer(sp.GetRequiredService<JsonCoreSerializer<TValue>>()) .SetValueDeserializer(sp.GetRequiredService<JsonCoreSerializer<TValue>>())
@ -115,6 +116,9 @@ public static class WarningCalcServiceExtension
QueueBufferingMaxKbytes = conf.GetValue<int>("Kafka:Producer:QueueBufferingMaxKbytes"), QueueBufferingMaxKbytes = conf.GetValue<int>("Kafka:Producer:QueueBufferingMaxKbytes"),
// 分区器 一致性hash/随机 // 分区器 一致性hash/随机
Partitioner = conf.GetValue<Partitioner>("Kafka:Producer:Partitioner"), Partitioner = conf.GetValue<Partitioner>("Kafka:Producer:Partitioner"),
// Debug = "all",
// LogConnectionClose = false,
// LogQueue = true
}) })
.SetKeySerializer(sp.GetRequiredService<JsonCoreSerializer<TKey>>()) .SetKeySerializer(sp.GetRequiredService<JsonCoreSerializer<TKey>>())
.SetValueSerializer(sp.GetRequiredService<JsonCoreSerializer<TValue>>()) .SetValueSerializer(sp.GetRequiredService<JsonCoreSerializer<TValue>>())