diff --git a/services/kafka_service.py b/services/kafka_service.py
index 80ea012..2f6fb99 100644
--- a/services/kafka_service.py
+++ b/services/kafka_service.py
@@ -40,6 +40,7 @@ class KafkaService:
             self.producer = AIOKafkaProducer(
                 bootstrap_servers=self.bootstrap_servers,
                 compression_type="gzip"
+                max_request_size=104857600
             )
             await self.producer.start()
         except KafkaError as e: