我正在尝试从nodejs中的nasdaq收集数据流,就像他们在这个存储库中使用java一样https://github.com/nasdaq/clouddataservice.
我面临的问题是我找不到任何方法来传递信任:
const kafka = new Kafka({
clientId: 'client-id',
brokers: ['borker:9094'],
// authenticationTimeout: 1000,
// reauthenticationThreshold: 10000,
ssl: true,
sslOptions: {
trustStore: "ncdsTrustStore.p12",
trustStorePassword:"pass_word",
trustStoreType:"PKCS12"
},
logLevel: logLevel.ERROR,
sasl: {
mechanism: 'oauthbearer',
oauthBearerProvider: async () => {
const token = "TOKEN"
console.log(token)
return {
value: token
}
}
},
})
暂无答案!
目前还没有任何答案,快来回答吧!