diff --git a/src/consumer/base_consumer.rs b/src/consumer/base_consumer.rs
index a25e36611..6096d8d21 100644
--- a/src/consumer/base_consumer.rs
+++ b/src/consumer/base_consumer.rs
@@ -713,7 +713,10 @@ where
         topic: Option<&str>,
         timeout: T,
     ) -> KafkaResult<Metadata> {
-        self.client.fetch_metadata(topic, timeout)
+        let to = timeout.into();
+        // force credential retrieval
+        self.client.poll_event(&self.queue, to);
+        self.client.fetch_metadata(topic, to)
     }
 
     fn fetch_watermarks<T: Into<Timeout>>(