From a5b851ea3d979787d5f95a8fb00290cd0c6b4663 Mon Sep 17 00:00:00 2001
From: Pranav Rathi <4427674+pranavrth@users.noreply.github.com>
Date: Mon, 14 Oct 2024 12:42:09 +0530
Subject: [PATCH] Fixing test with sleep

---
 .../consumer/test_consumer_topicpartition_metadata.py           | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/tests/integration/consumer/test_consumer_topicpartition_metadata.py b/tests/integration/consumer/test_consumer_topicpartition_metadata.py
index 0ac2b4466..5be8c6757 100644
--- a/tests/integration/consumer/test_consumer_topicpartition_metadata.py
+++ b/tests/integration/consumer/test_consumer_topicpartition_metadata.py
@@ -15,6 +15,7 @@
 # See the License for the specific language governing permissions and
 # limit
 
+import time
 from confluent_kafka import TopicPartition
 
 
@@ -34,6 +35,7 @@ def test_consumer_topicpartition_metadata(kafka_cluster):
     consumer_conf = {'group.id': 'pytest'}
 
     c = kafka_cluster.consumer(consumer_conf)
+    time.sleep(2)
 
     # Commit without any metadata.
     metadata = None