Skip to content

Commit b7041c8

Browse files
use default oauth callback if none is passed (#507)
Co-authored-by: Maciej Mensfeld <[email protected]>
1 parent bb7f40c commit b7041c8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

lib/rdkafka/config.rb

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -338,7 +338,9 @@ def native_config(opaque = nil)
338338
Rdkafka::Bindings.rd_kafka_conf_set_error_cb(config, Rdkafka::Bindings::ErrorCallback)
339339

340340
# Set oauth callback
341-
Rdkafka::Bindings.rd_kafka_conf_set_oauthbearer_token_refresh_cb(config, Rdkafka::Bindings::OAuthbearerTokenRefreshCallback)
341+
if Rdkafka::Config.oauthbearer_token_refresh_callback
342+
Rdkafka::Bindings.rd_kafka_conf_set_oauthbearer_token_refresh_cb(config, Rdkafka::Bindings::OAuthbearerTokenRefreshCallback)
343+
end
342344
end
343345
end
344346

0 commit comments

Comments
 (0)