Fixing test with sleep

Author: pranavrth

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