卡夫卡在控制台生产

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

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

当前回答

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

其他回答

在服务器上添加侦听器设置后，问题得到解决。属性文件位于配置目录。 listener =PLAINTEXT://localhost(或您的服务器):9092 修改完成后重新启动kafka。使用版本2.11

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

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

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

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

我也得到了同样的错误消息

获取关联id为39的元数据时出错: {4-3-16-topic1 = LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

解决步骤:

去C:\Windows\System32\drivers\etc\hosts 如果下面的行不存在，那么将它添加到hosts文件的末尾

127.0.0.1       localhost

打开C:\<Kafka_Config_Path>\server。属性，并在文件末尾添加

    advertised.listeners = PLAINTEXT://localhost:9092
    listeners = PLAINTEXT://0.0.0.0:9092

重新启动Kafka服务器

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

推荐文章