1 fichiers modifiés avec 2 ajouts et 1 suppressions
+ 2
- 1
services/kafka_service.py
Voir le fichier
| @@ -39,7 +39,8 @@ class KafkaService: | |||||
| try: | try: | ||||
| self.producer = AIOKafkaProducer( | self.producer = AIOKafkaProducer( | ||||
| bootstrap_servers=self.bootstrap_servers, | bootstrap_servers=self.bootstrap_servers, | ||||
| compression_type="gzip", | |||||
| # compression_type="gzip", | |||||
| compression_type="snappy", # 或者 "lz4" | |||||
| max_request_size=104857600 | max_request_size=104857600 | ||||
| ) | ) | ||||
| await self.producer.start() | await self.producer.start() | ||||
Chargement…