一段时间以来,我一直在使用共享集群设置来测试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 用于最近没有配置更改的节点应用程序。我的共享实例有问题吗?任何尝试的建议。
谢谢!