卡夫卡在控制台生产

我试着用卡夫卡。所有配置都正确完成，但当我试图从控制台产生消息时，我一直得到以下错误

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

当前回答

这是我在config/server中添加的。属性，这解决了我的问题类似上述问题。希望这有助于，它在服务器中有很好的文档。属性文件，在修改此文件之前，请尝试阅读和理解。 advertised.listeners =明文:/ / < your_kafka_server_ip >: 9092

其他回答

当LEADER_NOT_AVAILABLE错误抛出时，只需重新启动kafka代理:

/bin/kafka-server-stop.sh

紧随其后的是

/bin/kafka-server-start.sh config/server.properties

(注意:Zookeeper必须在这个时候运行，否则它不会工作)

我让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任务定义中的主机名

我知道这是很久以前发布的，我想分享我是如何解决它的。因为我有我的办公室笔记本电脑(VPN和代理配置)。我检查了环境变量NO_PROXY

> echo %NO_PROXY%

返回空值现在我已经设置了NO_PROXY与localhost和127.0.0.1

> set NO_PROXY=127.0.0.1,localhost

如果您想追加现有值，则

> set NO_PROXY=%NO_PROXY%,127.0.0.1,localhost

在这之后，我重新启动了zookeeper和kafka 工作起来很有魅力

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

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

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

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

推荐文章