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

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

这个警告(在0.10.2.1中)的另一种可能是，你试图对一个刚刚创建的主题进行投票，而这个主题分区的领导者还不可用，你正在进行领导者选举。

在主题创建和轮询之间等待一秒钟是一种变通方法。

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

上述答案中提到的广告听众可能是原因之一。其他可能的原因有:

主题可能还没有创建。你可以使用bin/kafka-topics——list——zookeeper <zookeeper ip>:<zookeeper port>来检查 检查您提供给生成器以获取元数据的引导服务器。如果引导服务器不包含关于主题的最新元数据(例如，当它丢失其zookeeper声明时)。您必须添加多个引导服务器。

另外，确保已将所发布的侦听器设置为IP:9092而不是localhost:9092。后者意味着只能通过本地主机访问代理。

当我遇到错误时，我记得在引导服务器(或代理列表)列表中使用了PLAINTEXT://<ip>:<PORT>，它工作了，奇怪的是。

bin/kafka-console-producer --topic sample --broker-list PLAINTEXT://<IP>:<PORT>

当我们试图订阅一个尚未创建的主题时，我们往往会收到这条消息。我们通常依赖于在部署环境中预先创建的主题，但我们有针对dockerized kafka实例运行的组件测试，每次都干净启动。

在这种情况下，我们在测试设置中使用AdminUtils来检查主题是否存在，如果不存在就创建它。有关设置AdminUtils的更多信息，请参阅另一个堆栈溢出。

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

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