diff --git a/pkg/rdkafka/RdKafkaContext.php b/pkg/rdkafka/RdKafkaContext.php
index 9930b56ee..d671c50fe 100644
--- 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;