Add oauthbearer_token_refresh_cb config value for setting setOauthbearerTokenRefreshCb

scorgn · scorgn · commit b391da8a41f9 · 2024-10-24T17:34:10.000-04:00
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;

Original file line number	Diff line number	Diff line change
`@@ -216,6 +216,10 @@ private function getConf(): Conf`
`216`	`216`	`if (isset($this->config['stats_cb'])) {`
`217`	`217`	`$this->conf->setStatsCb($this->config['stats_cb']);`
`218`	`218`	`}`
	`219`	`+`
	`220`	`+ if (isset($this->config['oauthbearer_token_refresh_cb'])) {`
	`221`	`+ $this->conf->setOauthbearerTokenRefreshCb($this->config['oauthbearer_token_refresh_cb']);`
	`222`	`+ }`
`219`	`223`	`}`
`220`	`224`
`221`	`225`	`return $this->conf;`