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

Kafka经纪人没有启动

虞华翰
2023-03-14

我有两个< code>kafka 0.10.1的代理集群,之前在我的开发服务器上正确运行< code>zookeeper 3.3.6。

我最近尝试将broker版本升级到最新的kafka 2.3.0,但没有开始。配置没有太大变化
谁能告诉我可能会出什么问题吗。为什么经纪人没有起步?

已更改服务器。代理服务器1上的属性

broker.id=1
log.dirs=/mnt/kafka_2.11-2.3.0/logs
zookeeper.connect=local1:2181,local2:2181
listeners=PLAINTEXT://local1:9092
advertised.listeners=PLAINTEXT://local1:9092

已更改代理服务器2上的server.properties

broker.id=2
log.dirs=/mnt/kafka_2.11-2.3.0/logs
zookeeper.connect=local1:2181,local2:2181
listeners=PLAINTEXT://local2:9092
advertised.listeners=PLAINTEXT://local2:9092

注意:
1.Zookeeper正在两台服务器上运行
2.正在创建Kafka目录,即/brokers、/brokers/ids、/consumers等
3.没有在/brokers/ids下注册任何内容。Zookeeper CLIget/brokers/ids返回[]4.命令
4.日志/服务器。日志
没有记录错误
5.没有更多日志被附加到server.log

服务器日志

[2019-07-01 10:56:14,534]信息 启动默认周期为 9223372036854775807 毫秒的日志刷新器 (kafka.log.LogManager)
[2019-07-01 10:56:14,801] 信息正在等待本地 2:9092 上的套接字连接。(kafka.network.Acceptor)
[2019-07-01 10:56:14,829] 信息 [SocketServer brokerId=1] 为endpoint创建了数据平面接受器和处理器 : EndPoint(local2,9092,侦听器名称(纯文本),纯文本) (kafka.network.SocketServer)
[2019-07-01 10:56:14,830] 信息 [SocketServer 代理 Id=1] 为数据平面启动了 1 个受体线程 (kafka.network.SocketServer)
[2019-07-01 10:56:14,850] 信息 [过期返回-1-Produce]: 启动 (kafka.server.延迟操作失效$过期操作返回)
[2019-07-01 10:56:14,851]信息 [过期刷新 1-提取]: 正在启动 (kafka.server.延迟操作清除$过期操作返回者)
[2019-07-01 10:56:14,851] 信息 [过期返回者-1-删除记录]: 正在启动 (kafka.server.延迟操作清除$过期操作返回者)
[2019-07-01 10:56:14,852] 信息 [过期返回者-1-选择首选领导者]: 正在启动(kafka.server.延迟操作清除$过期操作返回者)
[2019-07-01 10:56:14,860]INFO [LogDirFailureHandler]: 正在启动 (kafka.server.ReplicaManager$LogDirFailureHandler)
[2019-07-01 10:56:14,892] 信息 正在创建 /brokers/ids/1 (安全吗?

共有1个答案

楚岳
2023-03-14

关于ZooKeeper稳定版的文档

当前的稳定分支是 3.4,该分支的最新版本是 3.4.9。

将动物园管理员版本升级到最新的3.5.5有所帮助,Kafka经纪人正确启动。
如果文档能够说明与以前的动物园管理员版本不兼容,那就太好了。
PS:添加了答案,以帮助某人因为动物园管理员版本而遇到类似问题。

 类似资料:
  • Kafka初学者和融合包。我想启动多个代理,以便了解主题。可以通过此设置完成- 此设置可以在服务器配置文件中定义,也可以在脚本中定义。 但是我该如何运行它们呢?。如果我只是向引导服务器添加多个endpoint,就会出现以下错误: Java . lang . illegalargumentexception:要求失败:每个侦听器必须有不同的名称,listeners: PLAINTEXT://:909

  • 我正在尝试仅为代理间kerberos配置Kafka代理。然而,由于它似乎也想通过Kerberos连接到Zookeeper,所以我似乎总是遇到错误。我目前还没有设置任何Zookeeper键。 我的Kafka代理 JAAS 配置如下: 服务器属性 我用上述配置得到的错误如下: 换句话说,我只想要经纪人到经纪人的 kerberos 和经纪人 - 动物园管理员的普通SASL_SSL。这可能吗?

  • 我试图连接到Kafka服务器使用SpringKafka客户端 我正在使用logback。xml。下面是配置。在测试之前,我对Kafka主机和端口进行了硬编码。相同的代码和配置适用于其中一个环境。

  • 我知道生产者/消费者需要与经纪人交谈以了解分区的领导者。经纪人与zk交谈以告诉他们加入了集群。 是真的吗 经纪人从zk知道谁是给定分区的负责人 zk发现经纪人离开/死亡。然后重新选举领导人,并向所有经纪人发送新的领导人信息 问题: 为什么我们需要经纪人相互沟通?这只是为了让tehy可以移动分区,或者他们也可以互相查询元数据。如果是这样,元数据交换的例子是什么

  • 我在Windows子系统Linux上安装了kafka,并开始使用命令服务启动,所有服务都已启动。现在,当我尝试从Windows运行我的kafka-spring应用程序时,它显示以下错误:- 无法建立与节点-1(localhost/127.0.0.1:9092)的连接。经纪人可能不可用。 我的服务器属性是:- 我哪里出错了???

  • 在Flink中,我执行以下代码: 我推出3次同样的工作。 如果我用一个代理执行这段代码,它工作得很好,但是用3个broke(在3个不同的机器上)只读取一个分区。 null