From 61863c469b964a0c5d3f9457fed891b78224464d Mon Sep 17 00:00:00 2001 From: liujl Date: Fri, 11 Sep 2026 03:30:34 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E6=88=908m?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../syslog-serve/src/main/java/com/kafka/kafkaProducer.java | 2 +- .../syslog-serve/src/main/resources/application.properties | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/haobang-security-dm/syslog-serve/src/main/java/com/kafka/kafkaProducer.java b/haobang-security-dm/syslog-serve/src/main/java/com/kafka/kafkaProducer.java index e1675bc..d14e355 100644 --- a/haobang-security-dm/syslog-serve/src/main/java/com/kafka/kafkaProducer.java +++ b/haobang-security-dm/syslog-serve/src/main/java/com/kafka/kafkaProducer.java @@ -53,7 +53,7 @@ public class kafkaProducer { @Value("${spring.kafka.producer.compression-type:lz4}") String compressionType, @Value("${spring.kafka.producer.properties.max.block.ms:10000}") int maxBlockMs, @Value("${spring.kafka.producer.properties.buffer.memory:134217728}") long bufferMemory, - @Value("${spring.kafka.producer.properties.max.request.size:4194304}") int maxRequestSize, + @Value("${spring.kafka.producer.properties.max.request.size:8388608}") int maxRequestSize, @Value("${syslog.kafka.partition-key-strategy:event_id}") String partitionKeyStrategy) { this.appProperties = appProperties; this.partitionKeyStrategy = PartitionKeyStrategy.parse(partitionKeyStrategy); diff --git a/haobang-security-dm/syslog-serve/src/main/resources/application.properties b/haobang-security-dm/syslog-serve/src/main/resources/application.properties index d1fce49..c00a8dc 100644 --- a/haobang-security-dm/syslog-serve/src/main/resources/application.properties +++ b/haobang-security-dm/syslog-serve/src/main/resources/application.properties @@ -87,7 +87,7 @@ spring.kafka.producer.properties.delivery.timeout.ms=120000 spring.kafka.producer.properties.max.block.ms=10000 spring.kafka.producer.properties.buffer.memory=134217728 # 允许投递加密后超过 Kafka 默认 1 MiB 的 Syslog；Broker/Topic 上限必须不小于此值。 -spring.kafka.producer.properties.max.request.size=${KAFKA_PRODUCER_MAX_REQUEST_SIZE:4194304} +spring.kafka.producer.properties.max.request.size=${KAFKA_PRODUCER_MAX_REQUEST_SIZE:8388608} # event_id 使高流量设备的独立事件均匀分布到多个分区；device_id 仅用于兼容回滚。 syslog.kafka.partition-key-strategy=${SYSLOG_KAFKA_PARTITION_KEY_STRATEGY:event_id}