当前位置: 首页 > 知识库问答 >
问题:

kafka动物园管理员远程=错误

艾飞宇
2023-03-14

我正在尝试安装Kafka

Kafka和Zookeeper正在运行Apache Kafka tarball(v 0 . 0 . 9 ),在Docker映像中。

尝试使用提供的脚本消费/生产。并尝试使用自己的java应用程序进行生产。如果Kafka一切正常

以下是我在尝试生成时遇到的错误:

BrokerPartitionInfo:83 - Error while fetching metadata [{TopicMetadata for topic RSS ->
No partition metadata for topic RSS due to kafka.common.LeaderNotAvailableException}] for topic [RSS]: class kafka.common.LeaderNotAvailableException

Kafka属性测试

首先:

borker.id=0
port=9092
host.name=<external-ip>
zookeeper.connect=localhost:<PORT>

第二:

borker.id=0
port=9092
host.name=<external-ip>
zookeeper.connect=<external-ip>:<PORT>

第三:

borker.id=0
port=9092
host.name=<external-ip>
zookeeper.connect=<external-ip>:<PORT>
advertised.host.name=<external-ip>
advertised.host.port=<external-ip>

上一个:

borker.id=0
port=9092
host.name=</etc/host name>
zookeeper.connect=<external-ip>:<PORT>
advertised.host.name=<external-ip>
advertised.host.port=<external-ip>

这是我的“/etc/hosts”

127.0.0.1 kafka kafka
127.0.0.1 localhost  

我遵循了入门指南,如果我理解它是localhost/signle服务器配置。我无法理解我需要做什么才能通过远程通话完成这项工作。。。

谢谢你的帮助!

编辑1

host.name=localhost
advertised.host.name=politik.cm-cloud.fr

似乎允许本地消费者(在服务器上)和生产者。但是如果我们想从远程服务器上做同样的事情,我们会得到

[2015-12-09 12:44:10,826] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)
java.net.NoRouteToHostException: No route to host

共有1个答案

堵恺
2023-03-14

这个错误看起来不像是Zoo门/Kafka的连接问题。只需按照http://kafka.apache.org/的“快速入门”中的说明进行操作

BrokerPartitionInfo:83 - Error while fetching metadata [{TopicMetadata for topic RSS ->

此外,该错误表明没有分区信息,即尚未创建主题。首先尝试创建主题,然后尝试生成/消费,因为当生成不存在的主题时,kafka 将基于 server.properties 中的 auto.create.topics.enable 创建主题,但远程创建主题比依赖自动创建更好

 类似资料:
  • 我正在为Storm开发代码,这是开发人员的一个示例。我的问题是,当您从IDE Eclipse运行此代码时,不会建立Storm和ZooKeer之间的连接。ZooKeer在2181中运行,也设置在storm.yaml. 我的例外是: 有什么想法或程序要执行吗?是否从配置代码中传递?和我一样?

  • 分布式 Apache HBase 安装依赖于正在运行的 ZooKeeper 集群。所有参与节点和客户端都需要能够访问正在运行的 ZooKeeper 集合。 Apache HBase 默认为您管理 ZooKeeper“集群”。它将启动和停止 ZooKeeper 集合作为 HBase 启动/停止过程的一部分。您还可以独立于 HBase 管理 ZooKeeper 集合,只需将 HBase 指向它应该使用

  • 假设我有 3 台 Kafka 服务器。服务器 1 zoopkeeper1 服务器 2 zoopkeeper2 服务器 3 zoopkeeper3 在集群配置中,zoopkeepers 会发生什么?它们是为每个服务器单独维护的,还是会在群集配置中同步其数据?

  • 在Zookeeper和代理身份验证上启用SASL时,我面临以下错误。 以下配置在JAAS文件中给出,该文件作为KAFKA_OPTS传递,将其作为JVM参数:- Kafka经纪人的服务器。属性设置了以下额外字段:- Zookeeper属性如下所示:

  • 如果我部署war,我将得到以下异常: 原因:org.apache.camel.resolveEndpointFailedException:无法解析endpoint:kafka://localhost:9092?serializerClass=kafka.serializer.stringencoder&topic=checking&zookeePerhost=localhost&zookeePe

  • 我已经设置了一个带有SASL SCRAM安全性的Kafka集群,它运行良好。 根据文档,我使用了命令< code>kafka-configs.sh来创建用户名和密码,并授予该用户对主题的访问权限。 这也很棒。 但是, 命令本身不需要任何类型的身份验证,因此在我看来,任何人都可以运行该命令并在Kafka中创建自己的用户并授予自己的权限。 也许我需要在Zookeeper上启用SASL安全性?但我找不到