Fixing test

confluentinc · Oct 16, 2024 · 193f969 · 193f969
1 parent a5b851e
commit 193f969
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/tests/integration/consumer/test_consumer_topicpartition_metadata.py b/tests/integration/consumer/test_consumer_topicpartition_metadata.py
@@ -35,7 +35,8 @@ def test_consumer_topicpartition_metadata(kafka_cluster):
     consumer_conf = {'group.id': 'pytest'}
 
     c = kafka_cluster.consumer(consumer_conf)
-    time.sleep(2)
+    c.subscribe([topic])
+    time.sleep(5)
 
     # Commit without any metadata.
     metadata = None