Force auth when fetching Kafka metadata

fede1024 · Dec 10, 2024 · e962c8c · e962c8c
1 parent 5079920
commit e962c8c
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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>>(