From b46bad65000176e3b938da039ff42230ec6c3dd1 Mon Sep 17 00:00:00 2001
From: H Vs <vson.iwork@outlook.com>
Date: Wed, 2 Apr 2025 16:54:18 +0800
Subject: [PATCH] =?UTF-8?q?kafka=20=E8=B0=83=E6=95=B4=20max=5Frequest=5Fsi?=
 =?UTF-8?q?ze?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 services/kafka_service.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/services/kafka_service.py b/services/kafka_service.py
index 80ea012..2f6fb99 100644
--- a/services/kafka_service.py
+++ b/services/kafka_service.py
@@ -40,6 +40,7 @@ class KafkaService:
             self.producer = AIOKafkaProducer(
                 bootstrap_servers=self.bootstrap_servers,
                 compression_type="gzip"
+                max_request_size=104857600
             )
             await self.producer.start()
         except KafkaError as e: