1 changed files with 1 additions and 0 deletions
+ 1
- 0
services/kafka_service.py
View File
| @@ -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: | |||
Loading…