From b0a8c0bd8d2d556c12a7c5ce81a377bacfa0ed74 Mon Sep 17 00:00:00 2001 From: H Vs Date: Wed, 2 Apr 2025 16:55:28 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/kafka_service.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/services/kafka_service.py b/services/kafka_service.py index 2f6fb99..beef4d1 100644 --- a/services/kafka_service.py +++ b/services/kafka_service.py @@ -39,7 +39,7 @@ class KafkaService: try: self.producer = AIOKafkaProducer( bootstrap_servers=self.bootstrap_servers, - compression_type="gzip" + compression_type="gzip", max_request_size=104857600 ) await self.producer.start()