Клиент Kafka-узла продолжает отправлять запрос брокеру, который вышел из строя - PullRequest
Новая
       10

Клиент Kafka-узла продолжает отправлять запрос брокеру, который вышел из строя

0 голосов
/ 23 октября 2018

Когда хост-брокер отключается / перезапускается, клиент kafka продолжает отправлять новые запросы на те же хосты.В результате запросы не выполняются с этой ошибкой: истекло время ожидания запроса после 30000 мс.

Версия узла: v6.8.1
Версия Kafka-узла: 3.0.1
Версия Kafka: 2.11-2.0.0
Количество брокеров: 3
Количество разделов для темы: 10

Некоторые указатели кода: 

"clusterConfig" : {
  "kafkaHost": "localhost:9092,localhost:9093,localhost:9094",
  "autoConnect": true
}
...
let kafkaClient = new kafka.KafkaClient(clusterConfig);
producer = new kafka.HighLevelProducer(kafkaClient, cluster.producerConfig);
Promise.promisifyAll(producer);
...
producer.sendAsync([eventPayload])
  .then(function (data) {
    let topicName = eventPayload.topic;
    let payLoadSize = (eventPayload || '').length;
    logger.eventInfo(topicName, payLoadSize, source);
  })
  .catch(function (e) {
    logger.produceFailedEvent(eventPayload, source);
    throw Error.getErrorObject(errorType, e, topic, source);
  });

Я оставил другие конфигурации по умолчанию.Пожалуйста, помогите в решении проблемы.

Спасибо, Шашанк

...