我试着用卡夫卡。 所有配置都正确完成，但当我试图从控制台产生消息时，我一直得到以下错误
WARN Error while fetching metadata with correlation id 39 :
{4-3-16-topic1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
Kafka版本:2.11-0.9.0.0
当前回答
对我来说，原因是使用了一个特定的Zookeeper，这不是Kafka包的一部分。该Zookeeper已经安装在机器上用于其他目的。显然卡夫卡不会和任何一个动物园管理员合作。切换到卡夫卡附带的Zookeeper为我解决了这个问题。为了不与现有的Zookeeper发生冲突，我不得不修改我的配置，让Zookeeper监听不同的端口:
[root@host /opt/kafka/config]# grep 2182 *
server.properties:zookeeper.connect=localhost:2182
zookeeper.properties:clientPort=2182
其他回答
我使用的是kafka_2.12-0.10.2.1:
vi problem / server . properties
加到下面一行:
listeners=PLAINTEXT://localhost:9092
不需要更改广告。当它拾取值时监听器 从STD侦听器属性。
代理将向生产者和消费者发布主机名和端口。如果没有设置，
如果配置了“监听器”，则使用该值
否则，它将使用从java.net.InetAddress.getCanonicalHostName()返回的值。
停止Kafka代理:
bin/kafka-server-stop.sh
重新启动代理:
bin/kafka-server-start.sh -daemon config/server.properties
现在你应该不会看到任何问题。
以我为例，它在家里工作得很好，但在办公室里，当我连接到办公室网络时，它就不行了。
所以修改了config/server.properties 监听器=明文://:9092 to监听器=明文://localhost:9092
在我的例子中，我是在描述消费者群体时得到的
对于我来说，我没有为Kafka实例指定代理id。 当它在Docker环境中重启时，有时会从zookeeper获取一个新的id。 如果您的代理id大于1000，只需指定环境变量KAFKA_BROKER_ID。
使用它可以查看代理、主题和分区。
brew install kafkacat
kafkacat -b [kafka_ip]:[kafka_poot] -L
这个警告(在0.10.2.1中)的另一种可能是，你试图对一个刚刚创建的主题进行投票，而这个主题分区的领导者还不可用，你正在进行领导者选举。
在主题创建和轮询之间等待一秒钟是一种变通方法。
我使用docker-compose来构建使用wurstmeister/ Kafka映像的Kafka容器。在docker-compose文件中添加KAFKA_ADVERTISED_PORT: 9092属性为我解决了这个错误。
