bugfix

Bot-detector · Feb 6, 2024 · 113dc51 · 113dc51
1 parent fedd57f
commit 113dc51
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/src/jobs/kafka/players/main.py b/src/jobs/kafka/players/main.py
@@ -19,7 +19,6 @@
 async def check_total_consumer_lag(topic: str, group_id:str = "scraper"):
     consumer = AIOKafkaConsumer(
         bootstrap_servers=[APPCONFIG.KAFKA_HOST],
-        topic=topic,
         group_id=group_id
     )
     total_lag = 0