我在 GKE 上使用 srimzi 运算符 0.15 版部署了 Kafka,并且工作正常。配置是这样的:
kafka:
version: 2.3.1
replicas: 3
config:
offsets.topic.replication.factor: 3
transaction.state.log.replication.factor: 3
transaction.state.log.min.isr: 2
log.message.format.version: "2.3"
当我对 kubernetes 集群进行升级时,显然每个 Kafka Pod 也已重新启动,并且在升级过程中,我在尝试与 Kafka 通信的客户端的日志中看到了以下许多消息:
xxx 分区有没有匹配侦听器的领导代理,包括....
和
无法建立与节点 1 (kafka-1.redacted.svc.cluster.local/redacted:9092) 的连接。经纪人可能不可用。
所以,我想知道这是正常行为还是不应该发生。GKE 升级后一切正常,没有任何问题。
在升级过程中,kafka-exporter(与 strimzi 操作员一起部署)也在记录:
在领导选举过程中,该分区当前没有领导,因此无法写入
谢谢你的帮助