merge

karafka · Sep 13, 2024 · 46b4f31 · 46b4f31
2 parents bddc27d + c38a389
commit 46b4f31
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,8 @@
 # Rdkafka Changelog
 
+## 0.17.7 (Unreleased)
+- [Enhancement] Use default oauth callback if none is passed (bachmanity1)
+
 ## 0.17.6 (2024-09-03)
 - [Fix] Fix incorrectly behaving CI on failures. 
 - [Fix] Fix invalid patches librdkafka references.

diff --git a/lib/rdkafka/config.rb b/lib/rdkafka/config.rb
@@ -338,7 +338,9 @@ def native_config(opaque = nil)
         Rdkafka::Bindings.rd_kafka_conf_set_error_cb(config, Rdkafka::Bindings::ErrorCallback)
 
         # Set oauth callback
-        Rdkafka::Bindings.rd_kafka_conf_set_oauthbearer_token_refresh_cb(config, Rdkafka::Bindings::OAuthbearerTokenRefreshCallback)
+        if Rdkafka::Config.oauthbearer_token_refresh_callback
+          Rdkafka::Bindings.rd_kafka_conf_set_oauthbearer_token_refresh_cb(config, Rdkafka::Bindings::OAuthbearerTokenRefreshCallback)
+        end
       end
     end
 

diff --git a/lib/rdkafka/version.rb b/lib/rdkafka/version.rb
@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
 module Rdkafka
-  VERSION = "0.17.6"
+  VERSION = "0.17.7"
   LIBRDKAFKA_VERSION = "2.5.3"
   LIBRDKAFKA_SOURCE_SHA256 = "eaa1213fdddf9c43e28834d9a832d9dd732377d35121e42f875966305f52b8ff"
 end