【问题标题】:Kafka brokers not starting up卡夫卡经纪人没有启动
【发布时间】:2019-11-11 19:26:26
【问题描述】:

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

我最近尝试将代理版本升级到最新的kafka 2.3.0,但它没有启动。 配置没有太大变化。
任何人都可以指导我可能会出错的地方。为什么经纪人还没有开始?

更改了代理服务器 1 上的 server.properties

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 CLI get /brokers/ids 返回 [] 4. 命令lsof -i tcp:9082返回
COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME java 18290 cass 118u IPv6 52133 0t0 TCP local2:9092 (LISTEN)
4. logs/server.log 没有记录错误。
5. 没有更多的日志被附加到server.log

服务器日志

[2019-07-01 10:56:14,534] INFO 启动日志刷新器,默认周期为 9223372036854775807 毫秒。 (kafka.log.LogManager)
[2019-07-01 10:56:14,801] 信息等待 local2:9092 上的套接字连接。 (kafka.network.Acceptor)
[2019-07-01 10:56:14,829] 信息 [SocketServer brokerId=1] 为端点创建数据平面接受器和处理器:EndPoint(local2,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer) [2019-07-01 10:56:14,830] 信息 [SocketServer brokerId=1] 为数据平面 (kafka.network.SocketServer) 启动了 1 个接受线程
[2019-07-01 10:56:14,850] 信息 [ExpirationReaper-1-Produce]:开始 (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-07-01 10:56:14,851] 信息 [ExpirationReaper-1-Fetch]:开始 (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-07-01 10:56:14,851] 信息 [ExpirationReaper-1-DeleteRecords]:开始 (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-07-01 10:56:14,852] 信息 [ExpirationReaper-1-ElectPreferredLeader]:开始 (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-07-01 10:56:14,860] 信息 [LogDirFailureHandler]:正在启动 (kafka.server.ReplicaManager$LogDirFailureHandler)
[2019-07-01 10:56:14,892] INFO 创建 /brokers/ids/1(安全吗?错误)(kafka.zk.KafkaZkClient)

【问题讨论】:

    标签: apache-kafka


    【解决方案1】:

    来自有关 ZooKeeper 的文档 稳定版

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

    将 zookeeper 版本升级到最新的3.5.5 帮助并正确启动了 Kafka 代理。
    如果文档说明与以前的 zookeeper 版本不兼容,那就太好了。
    PS:添加答案是为了帮助有人因为 zookeeper 版本而遇到类似问题。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2021-03-17
      • 1970-01-01
      • 1970-01-01
      • 2016-06-24
      • 1970-01-01
      • 2020-07-21
      • 2018-04-07
      • 2021-02-12
      相关资源
      最近更新 更多