From c4335aa3b7da4fc8b73e8eb3bbdba18650cd4dcf Mon Sep 17 00:00:00 2001 From: zenghongyao <873884283@qq.com> Date: Tue, 6 May 2025 15:28:00 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/JiShe.CollectBus.Kafka/Producer/ProducerService.cs | 2 +- web/JiShe.CollectBus.Host/Pages/Monitor.cshtml | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/modules/JiShe.CollectBus.Kafka/Producer/ProducerService.cs b/modules/JiShe.CollectBus.Kafka/Producer/ProducerService.cs index b2a3bc1..f37f3cc 100644 --- a/modules/JiShe.CollectBus.Kafka/Producer/ProducerService.cs +++ b/modules/JiShe.CollectBus.Kafka/Producer/ProducerService.cs @@ -70,7 +70,7 @@ namespace JiShe.CollectBus.Kafka.Producer BootstrapServers = _kafkaOptionConfig.BootstrapServers, //AllowAutoCreateTopics = true, QueueBufferingMaxKbytes = 2097151, // 4194304, // 修改缓冲区最大为2GB,默认为1GB - QueueBufferingMaxMessages = 100000, // 修改缓冲区消息最大为100000条,默认为1000条 + QueueBufferingMaxMessages = 100000, // 修改缓冲区消息最大为100000条 CompressionType = CompressionType.Lz4, // 配置使用压缩算法LZ4,其他:gzip/snappy/zstd BatchSize = 32_768, // 修改批次大小为32K LingerMs = 10, // 修改等待时间为20ms,默认为5ms diff --git a/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml b/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml index a58ded5..30e91e8 100644 --- a/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml +++ b/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml @@ -16,6 +16,7 @@ 后端服务 +