From b391da8a41f90da21dda836f8cdfd33b0c5cb7b1 Mon Sep 17 00:00:00 2001
From: Sarina Corrigan <26685104+scorgn@users.noreply.github.com>
Date: Thu, 24 Oct 2024 17:34:10 -0400
Subject: [PATCH] Add oauthbearer_token_refresh_cb config value for setting
 setOauthbearerTokenRefreshCb

---
 pkg/rdkafka/RdKafkaContext.php | 4 ++++
 1 file changed, 4 insertions(+)

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;