我有这个代码在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',
});
1条答案
按热度按时间tvmytwxo1#
我发现
node-rdkafka
没有办法使用sasl_oauth_token_provider
的这个配置属性,所以我只好放弃它而使用支持这个的KafkaJS
。