perf:GC调优System.GC.RetainVM:true,关闭librdkafka的日志,以减少内存占用
This commit is contained in:
parent
cf41c744c6
commit
5e43bf37f8
@ -24,4 +24,7 @@
|
||||
<ItemGroup>
|
||||
<None Update="kafkalib\**\*" CopyToPublishDirectory="Always" CopyToOutputDirectory="Always" />
|
||||
</ItemGroup>
|
||||
<PropertyGroup>
|
||||
<RetainVMGarbageCollection>true</RetainVMGarbageCollection>
|
||||
</PropertyGroup>
|
||||
</Project>
|
||||
|
||||
@ -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>>())
|
||||
|
||||
Loading…
Reference in New Issue
Block a user