diff --git a/src/consumer/base_consumer.rs b/src/consumer/base_consumer.rs
index a25e36611..b57d6c91b 100644
--- a/src/consumer/base_consumer.rs
+++ b/src/consumer/base_consumer.rs
@@ -713,6 +713,9 @@ where
         topic: Option<&str>,
         timeout: T,
     ) -> KafkaResult<Metadata> {
+        // force credential retrieval w/o wait time
+        self.client
+            .poll_event(&self.queue, Timeout::After(Duration::ZERO));
         self.client.fetch_metadata(topic, timeout)
     }