我知道这是很久以前发布的，我想分享我是如何解决它的。 因为我有我的办公室笔记本电脑(VPN和代理配置)。 我检查了环境变量NO_PROXY

> echo %NO_PROXY%

返回空值 现在我已经设置了NO_PROXY与localhost和127.0.0.1

> set NO_PROXY=127.0.0.1,localhost  

如果您想追加现有值，则

> set NO_PROXY=%NO_PROXY%,127.0.0.1,localhost  

在这之后，我重新启动了zookeeper和kafka 工作起来很有魅力

我尝试了这里列出的所有建议。对我有用的是去服务器。属性和添加:

port = 9092
advertised.host.name = localhost 

将监听器和advertised_listeners注释掉。

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

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

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

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

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

对我来说，原因是使用了一个特定的Zookeeper，这不是Kafka包的一部分。该Zookeeper已经安装在机器上用于其他目的。显然卡夫卡不会和任何一个动物园管理员合作。切换到卡夫卡附带的Zookeeper为我解决了这个问题。为了不与现有的Zookeeper发生冲突，我不得不修改我的配置，让Zookeeper监听不同的端口:

[root@host /opt/kafka/config]# grep 2182 *
server.properties:zookeeper.connect=localhost:2182
zookeeper.properties:clientPort=2182

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