调整

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