For all those struggling with the Kafka ssl setup and seeing this LEADER_NOT_AVAILABLE error. One of the reasons that might be broken is the keystore and truststore. In the keystore you need to have private key of the server + signed server certificate. In the client truststore, you need to have intermedidate CA certificate so that client can authenticate the kafka server. If you will use ssl for interbroker communication, you need this truststore also set in the server.properties of the brokers so they can authenticate each other.

我错误地漏掉了最后一篇文章，这让我痛苦地花了很多时间去寻找这个LEADER_NOT_AVAILABLE错误可能意味着什么。希望这能帮助到一些人。

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

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

port = 9092
advertised.host.name = localhost 

将监听器和advertised_listeners注释掉。

对我来说，这是由于配置失误造成的 Docker端口(9093) Kafka命令端口"bin/ Kafka -console-producer.sh——broker-list localhost:9092——topic TopicName" 我检查了我的配置匹配端口，现在一切正常

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

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

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

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

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