Fixing test with sleep

confluentinc · Oct 14, 2024 · a5b851e · a5b851e
1 parent 7dda52f
commit a5b851e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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