卡夫卡镜片制造者没有开始

Question

我正在升级我们的集群。然而，我有问题，试图让镜像制造者运行。

所以这台机器有卡夫卡经纪人和卡夫卡镜像制造者在运行。它们有独立的init脚本。

代理程序目前使用的是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运行良好，但是当我试图启动它时，镜像制造者马上就会死掉。

我在日志上看到了这个异常

    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

为了升级这一点，我同时做了代理和镜像制造者。我不确定我是否应该先升级所有的经纪人，然后再升级镜像制造者。

任何建议。如果我遵循同样的程序，首先升级所有代理，然后升级所有镜像制造者。一旦升级，就会影响server.properties中的协议。尽管文档似乎并不意味着：http://kafka.apache.org/documentation.html#upgrade

Answer 1

这个问题已经解决了。它们未启动的原因是配置文件上的选项更改或配置不正确。