chore: set api_version to prevent 1s lag in connection to kafka brokers

HumanSignal · Jun 24, 2024 · a389091 · a389091
1 parent 3ccd14f
commit a389091
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/utils.py b/server/utils.py
@@ -41,7 +41,7 @@ def ensure_topic(topic_name: str):
     retention_ms = settings.kafka_retention_ms
 
     admin_client = KafkaAdminClient(
-        bootstrap_servers=bootstrap_servers, client_id="topic_creator"
+        bootstrap_servers=bootstrap_servers, client_id="topic_creator", api_version=(2, 5, 0)
     )
 
     topic = NewTopic(
@@ -63,7 +63,7 @@ def delete_topic(topic_name: str):
     bootstrap_servers = settings.kafka_bootstrap_servers
 
     admin_client = KafkaAdminClient(
-        bootstrap_servers=bootstrap_servers, client_id="topic_deleter"
+        bootstrap_servers=bootstrap_servers, client_id="topic_deleter", api_version=(2, 5, 0)
     )
 
     admin_client.delete_topics(topics=[topic_name])