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