【发布时间】：2017-05-19 00:54:28
【问题描述】：
我正在升级我们的集群。但是我在尝试使镜像制造商运行时遇到问题。
所以这台机器有 kafka-brokers 和 kafka-mirrormakers 运行。它们有单独的初始化脚本。
代理目前使用 10.1.1.1 版本，镜像制造商使用 0.8.2-beta 版本。
它们都有自己的配置文件和位置
例如代理安装在 /server/kafka/ mirrormakers 安装在 /opt/kafka_mirrormaker 下。
这里是 brokers 的配置行，按照升级过程的说明：
inter.broker.protocol.version=0.10.1 log.message.format.version=0.8.2
对于镜像制作者：
inter.broker.protocol.version=0.8.2 log.message.format.version=0.8.2
所以我正在测试将其升级到 10.2.1，我尝试在一台主机上进行升级。 在我应用升级版本 10.2.1 后，Broker 运行良好，但是当我尝试启动它时，mirrormaker 立即死亡。
我在日志中看到了这个异常
Exception in thread "main" java.lang.NullPointerException
at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:309)
at kafka.tools.MirrorMaker.main(MirrorMaker.scala)
Exception in thread "MirrorMakerShutdownHook" java.lang.NullPointerException
at kafka.tools.MirrorMaker$.cleanShutdown(MirrorMaker.scala:399)
at kafka.tools.MirrorMaker$$anon$2.run(MirrorMaker.scala:222)
tail: kafka-mirrormaker-repl-sjc2-to-hkg1.out: file truncated
Exception in thread "main" java.lang.NullPointerException
at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:309)
at kafka.tools.MirrorMaker.main(MirrorMaker.scala)
Exception in thread "MirrorMakerShutdownHook" java.lang.NullPointerException
at kafka.tools.MirrorMaker$.cleanShutdown(MirrorMaker.scala:399)
at kafka.tools.MirrorMaker$$anon$2.run(MirrorMaker.scala:222)
还有这个
[2017-05-18 17:02:27,936] ERROR Exception when starting mirror maker. (kafka.tools.MirrorMaker$)
org.apache.kafka.common.config.ConfigException: Missing required configuration "bootstrap.servers" which has no default value.
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:436)
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:56)
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:63)
at org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:340)
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:191)
at kafka.tools.MirrorMaker$MirrorMakerProducer.<init>(MirrorMaker.scala:694)
at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:236)
at kafka.tools.MirrorMaker.main(MirrorMaker.scala)
由于这个已经配置，这个引导错误有点奇怪。 server.properties 将 localhost:9292 配置为 bootstrap.server
为了升级这个，我同时做了 broker 和 mirrormaker。我不确定我是否应该先升级所有代理，然后再升级镜像制造商。
任何建议。我是否应该遵循相同的程序，首先升级所有代理，然后升级所有镜像制造商。一旦他们升级了 server.properties 中的协议。即使文档似乎并不暗示：http://kafka.apache.org/documentation.html#upgrade
【问题讨论】：
标签： apache-kafka