Add oauthbearer_token_refresh_cb config value for setting setOauthbea…

…rerTokenRefreshCb
php-enqueue · Oct 24, 2024 · b391da8 · b391da8
1 parent 867d45f
commit b391da8
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/rdkafka/RdKafkaContext.php b/pkg/rdkafka/RdKafkaContext.php
@@ -216,6 +216,10 @@ private function getConf(): Conf
             if (isset($this->config['stats_cb'])) {
                 $this->conf->setStatsCb($this->config['stats_cb']);
             }
+
+            if (isset($this->config['oauthbearer_token_refresh_cb'])) {
+                $this->conf->setOauthbearerTokenRefreshCb($this->config['oauthbearer_token_refresh_cb']);
+            }
         }
 
         return $this->conf;