From 193f96988495f82efab3309d6cfaea12a8b1f508 Mon Sep 17 00:00:00 2001 From: Pranav Rathi <4427674+pranavrth@users.noreply.github.com> Date: Wed, 16 Oct 2024 13:25:26 +0530 Subject: [PATCH] Fixing test --- .../consumer/test_consumer_topicpartition_metadata.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/integration/consumer/test_consumer_topicpartition_metadata.py b/tests/integration/consumer/test_consumer_topicpartition_metadata.py index 5be8c6757..660749151 100644 --- 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