oauth-2.0 我需要将下面的python代码转换为nodejs,但我找不到任何与“sasl_oauth_token_provider”此属性对应的代码

c8ib6hqw  于 2022-10-31  发布在  Python
关注(0)|答案(1)|浏览(137)

我有这个代码在python中工作,我需要把它转换成nodejs,但是我找不到任何等价于sasl_oauth_token_provider这个属性的代码。

import time
from kafka import *
from kafka.errors import KafkaTimeoutError
from oauthlib.oauth2 import BackendApplicationClient
from requests_oauthlib import OAuth2Session

producer = KafkaProducer(bootstrap_servers='xxx',
                         security_protocol='SASL_SSL',
                         ssl_check_hostname=True,
                         sasl_mechanism='OAUTHBEARER',
                         sasl_plain_username=client_id,
                         sasl_plain_password=client_secret,
                         sasl_oauth_token_provider="xxx",
                         )

对于nodej,我使用node-rdkafka库,我得到的最接近的等效代码是-

const kafka = require('node-rdkafka');

const producer = new kafka.Producer({
'metadata.broker.list': 'xxx',
'security.protocol': 'sasl_ssl',
'sasl.mechanism': 'OAUTHBEARER',
'sasl.username': 'xxx',
'sasl.password': 'xxx',
});
tvmytwxo

tvmytwxo1#

我发现node-rdkafka没有办法使用sasl_oauth_token_provider的这个配置属性,所以我只好放弃它而使用支持这个的KafkaJS

相关问题