如何将信任库信息传递给kafka客户端配置

bogh5gae  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(239)

我正在尝试从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
      }
    }
  },
})

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题