Как передать информацию trustStore в конфигурацию клиента kafka

#node.js #apache-kafka #truststore

#node.js #apache-kafka #truststore

Вопрос:

Я пытаюсь собрать поток данных из nasdaq в NodeJS так же, как они делают это в этом репозитории с помощью 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
      }
    }
  },
})
 

Комментарии:

1. вы нашли какое-то решение?

2. Мне также интересно, нашли ли вы решение?