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