Что означает эта ошибка kafka при настройке общего кластера и как ее решить? - PullRequest
Новая
       29

Что означает эта ошибка kafka при настройке общего кластера и как ее решить?

0 голосов
/ 24 сентября 2019

Я уже некоторое время использую настройку общего кластера для тестирования некоторых вещей на CloudKarafka .Это не доставляло мне никаких проблем до вчерашнего дня, когда я начал получать это сообщение об ошибке.

{"level":"ERROR","timestamp":"2019-09-23T21:24:47.812Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 4)","broker":"velomobile-01.srvs.cloudkafka.com:9094","clientId":"kafkajs",**"error":"There is no leader for this topic-partition as we are in the middle of a leadership election"**,"correlationId":8,"size":333}

{ KafkaJSNumberOfRetriesExceeded
Caused by: KafkaJSProtocolError: There is no leader for this topic-partition as we are in the middle of a leadership election<br />
.
.
name: 'KafkaJSNumberOfRetriesExceeded', retriable: false, helpUrl: undefined, originalError:
{ KafkaJSProtocolError: There is no leader for this topic-partition as we are in the middle of a leadership election.

Я использую модуль npm kafkajs для приложения узла без изменений конфигурации в последнее время.Что-то не так с моим общим экземпляром?Любые предложения, чтобы попробовать.

Спасибо!

...