我也得到了同样的错误消息

获取关联id为39的元数据时出错: {4-3-16-topic1 = LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

解决步骤:

去C:\Windows\System32\drivers\etc\hosts 如果下面的行不存在，那么将它添加到hosts文件的末尾

127.0.0.1       localhost

打开C:\<Kafka_Config_Path>\server。属性，并在文件末尾添加

    advertised.listeners = PLAINTEXT://localhost:9092
    listeners = PLAINTEXT://0.0.0.0:9092

重新启动Kafka服务器

这可能与server.properties中的advertised.host.name设置有关。

可能发生的情况是，您的生产者试图找出谁是给定分区的领导者，找出它的advertised.host.name和advertised。端口并尝试连接。 如果这些设置没有正确配置，那么可能会认为领导者不可用。

在服务器上添加侦听器设置后，问题得到解决。属性文件位于配置目录。 listener =PLAINTEXT://localhost(或您的服务器):9092 修改完成后重新启动kafka。使用版本2.11

如果你在本地机器上运行kafka，尝试更新$KAFKA_DIR/config/server。以下行包含的属性: //localhost:9092然后重启kafka。

因为我想让我的kafka代理连接到远程生产者和消费者，所以我不想做广告。要注释掉的侦听器。在我的情况下，(在kubernetes上运行kafka)，我发现我的kafka pod没有分配任何集群IP。通过从服务中删除行clusterIP: None。呵呵，kubernetes给kafka pod分配了一个内部ip。这解决了我的LEADER_NOT_AVAILABLE问题，也解决了kafka生产者/消费者的远程连接问题。

在过去的两周里，当我和Kafka一起工作时，我一直在目睹同样的问题，从那时起我就一直在阅读这篇Stackoverflow的帖子。

经过2周的分析，我推断在我的情况下会发生这种情况 当尝试向不存在的主题生成消息时。

在我的例子中，结果是Kafka返回了一个错误消息，但在 同时，以前不存在的话题。因此，如果我尝试在此事件之后再次对该主题产生任何消息，错误将不再出现，因为主题已被创建。

请注意:这可能是我的特定Kafka安装配置为自动创建主题时，同样的不存在;这应该解释了为什么在我的情况下，我可以看到的问题只有一次为每个主题重置主题:你的配置可能是不同的，在这种情况下，你会一直收到相同的错误一遍又一遍。