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()