AWS MSK (Kafka) LEADER_NOT_AVAIABLE 同时将事件推送到主题

问题描述

我已经配置了 MSK，2 个节点，同时将消息推送到主题获得成功，但出现以下警告

 18:33:06.318 [kafka-producer-network-thread | producer-1]
  WARN  o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] 
  Error while fetching Metadata with correlation id 1: 
  {mytopic=leader_NOT_AVAILABLE}

任何想法为什么会这样？ 我的第一个猜测是我需要 2 个以上的节点。 谢谢。

解决方法

原因在于自动创建主题，当应用默认复制因子为 1 自动创建的主题时，当我使用正确的复制因子 3（与节点数相同）手动创建主题时，问题消失了。