我解决这个问题的方法是这样设置监听器:

advertised.listeners = PLAINTEXT://my.public.ip:9092
listeners = PLAINTEXT://0.0.0.0:9092

这使得KAFKA代理侦听所有接口。

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

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

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

port = 9092
advertised.host.name = localhost 

将监听器和advertised_listeners注释掉。

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

主题可能还没有创建。你可以使用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>

对于我来说，我没有为Kafka实例指定代理id。 当它在Docker环境中重启时，有时会从zookeeper获取一个新的id。 如果您的代理id大于1000，只需指定环境变量KAFKA_BROKER_ID。

使用它可以查看代理、主题和分区。

brew install kafkacat
kafkacat -b [kafka_ip]:[kafka_poot] -L

我让kafka作为Docker容器运行，类似的消息充斥在日志中。 KAFKA_ADVERTISED_HOST_NAME被设置为'kafka'。

在我的例子中，错误的原因是在“kafka”容器本身中缺少“kafka”的/etc/hosts记录。 因此，例如，在'kafka'容器中运行ping kafka将失败，使用ping: bad address 'kafka'

在Docker中，这个问题可以通过指定容器的主机名来解决。

实现它的选项:

Docker run——hostname… Docker运行-add-host… docker-compose中的主机名 AWS EC2任务定义中的主机名