擅长:python、mysql、java
<p>根据位于<a href="https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md" rel="nofollow noreferrer">https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md</a>的文档,必须使用<code>rd_kafka_conf_set_oauthbearer_token_refresh_cb()</code>设置<code>oauthbearer_token_refresh_cb</code>选项。但是请注意,您正试图将其设置为<code>TokenProvider</code>实例,该实例不可调用,因此您可能希望传递<code>TokenProvider(...).token</code></p>
<blockquote>
<p>SASL/OAUTHBEARER token refresh callback (set with
rd_kafka_conf_set_oauthbearer_token_refresh_cb(), triggered by
rd_kafka_poll(), et.al. This callback will be triggered when it is
time to refresh the client's OAUTHBEARER token.</p>
</blockquote>