Отказ транспортного брокера при подключении к производителю кафки - PullRequest
Новая
       10

Отказ транспортного брокера при подключении к производителю кафки

0 голосов
/ 31 января 2019

Из приложения Node.js я пытаюсь подключиться к брокеру Apache Kafka с помощью клиента node-rdkafka. Поскольку списки брокеров kafka включены с поддержкой SSL, то есть для настройки производителя node-rdkafka с параметрами ssl, как показано ниже:

Я уже пробовал с разными действующими сертификатами и ключами пытался добавить CA также с помощью опции ssl.ca.certificate:<CA-location>, но все равно не повезло.

Поискал на странице librdkafka github и нашел одну похожую проблему, в которой предлагаемое решение было использовать api.verison.request:false, пробовал тоже, но безуспешно. По-прежнему получаю ту же ошибку

Ошибка: сбой транспорта посредника

Попытка с использованием другого клиента kafka с именем no-kafka с тем же sslсертификат и ключи для подключения к одному и тому же списку посредников и возможность установить соединение.

Мы должны использовать только node-rdkafka.

Конфигурация производителя с использованием node-rdkafka: 

var producer = new Kafka.Producer({
    'debug':'All',
    'metadata.broker.list': 'comma separated list of ssl enabled broker hosts and port',
    'dr_cb': true,
    'security.protocol': 'ssl',
    'ssl.certificate.location': path.join(__dirname, 'server.crt'),
    'ssl.key.location': path.join(__dirname, 'server.key'),
    'ssl.ca.location' : path.join(__dirname,'DigiCertSHA2SecureServerCA-int.cer'),
  });

Я ожидаю, что SUCCESS MESSAGE говорит, что соединение установлено, но фактический результат - Error : Broker transport Failure

...