From 01a8f8eefc37f6a437c6796ed08c27f8a51d5dc0 Mon Sep 17 00:00:00 2001 From: H Vs Date: Wed, 2 Apr 2025 20:40:24 +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 | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/services/kafka_service.py b/services/kafka_service.py index 5bf64df..3027d30 100644 --- a/services/kafka_service.py +++ b/services/kafka_service.py @@ -39,8 +39,8 @@ class KafkaService: try: self.producer = AIOKafkaProducer( bootstrap_servers=self.bootstrap_servers, - # compression_type="gzip", - compression_type="snappy", # 或者 "lz4" + compression_type="gzip", + #compression_type="snappy", # 或者 "lz4" max_request_size=104857600 ) await self.producer.start()