Что означает эта ошибка кафки при настройке общего кластера и как ее решить?
Я уже некоторое время использую настройку общего кластера, чтобы протестировать некоторые вещи в 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 для приложения узла без изменений конфигурации в последнее время. Что-то не так с моим общим экземпляром? Любые предложения попробовать.
Спасибо!