【发布时间】: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