我试着用卡夫卡。 所有配置都正确完成，但当我试图从控制台产生消息时，我一直得到以下错误
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
当前回答
试试这个监听器=PLAINTEXT://localhost:9092 一定很有帮助
非常感谢
其他回答
试试这个监听器=PLAINTEXT://localhost:9092 一定很有帮助
非常感谢
以我为例，它在家里工作得很好，但在办公室里，当我连接到办公室网络时，它就不行了。
所以修改了config/server.properties 监听器=明文://:9092 to监听器=明文://localhost:9092
在我的例子中，我是在描述消费者群体时得到的
我使用的是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
现在你应该不会看到任何问题。
这可能与server.properties中的advertised.host.name设置有关。
可能发生的情况是，您的生产者试图找出谁是给定分区的领导者，找出它的advertised.host.name和advertised。端口并尝试连接。 如果这些设置没有正确配置，那么可能会认为领导者不可用。
对我来说，原因是使用了一个特定的Zookeeper，这不是Kafka包的一部分。该Zookeeper已经安装在机器上用于其他目的。显然卡夫卡不会和任何一个动物园管理员合作。切换到卡夫卡附带的Zookeeper为我解决了这个问题。为了不与现有的Zookeeper发生冲突，我不得不修改我的配置，让Zookeeper监听不同的端口:
[root@host /opt/kafka/config]# grep 2182 *
server.properties:zookeeper.connect=localhost:2182
zookeeper.properties:clientPort=2182
