Refresh OAuth token in the background

So that OAUTHBEARER authentication works even when poll isn't being called regularly (e.g., in a client just used for fetching metadata).
MaterializeInc · Aug 4, 2024 · 80fffc0 · 80fffc0
1 parent 1e27332
commit 80fffc0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/client.rs b/src/client.rs
@@ -268,6 +268,10 @@ impl<C: ClientContext + 'static> Client<C> {
 
         unsafe { rdsys::rd_kafka_set_log_level(client_ptr, config.log_level as i32) };
 
+        if C::ENABLE_REFRESH_OAUTH_TOKEN {
+            unsafe { rdsys::rd_kafka_sasl_background_callbacks_enable(client_ptr) };
+        }
+
         Ok(Client {
             native: unsafe { NativeClient::from_ptr(client_ptr) },
             context,