Ich bin dabei, unseren Cluster zu aktualisieren. Allerdings habe ich Probleme, die Spiegelmaschinen laufen zu lassen.Kafka mirrormaker starten nicht
So haben diese Maschinen Kafka-Broker und Kafka-Mirrormakers laufen. Sie haben separate Init-Skripte.
Die Broker verwenden derzeit die Version 10.1.1.1 und die Mirroracer verwenden die Version 0.8.2-beta.
haben Beide ihre eigenen Konfigurationsdateien und Standorte
zB Broker installiert sind in/server/kafka/ mirrormakers installiert werden unter/opt/kafka_mirrormaker.
Hier die Config-Linien für Makler nach dem, was der Upgrade-Prozess erklärt:
inter.broker.protocol.version = 0.10.1 log.message.format.version = 0.8.2
und für mirrormakers:
inter.broker. protocol.version = 0.8.2 log.message.format.version = 0.8.2
Also ich teste dies 10.2.1 zu aktualisieren habe ich versucht, das Upgrade in einem Host. Broker läuft gut, nachdem ich die Upgrade-Version 10.2.1 angewendet habe, aber der Spiegelserver stirbt sofort, als ich versuchte, es zu starten.
Ich sehe diese Ausnahme auf die Protokolle
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)
und dieses
[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)
Dieser Bootstrap-Fehler ist irgendwie komisch aufgrund dieser bereits Config. Die server.properties hat localhost: 9292 als bootstrap.server konfiguriert
Um dies zu aktualisieren habe ich Broker und Spiegelmaschine zur gleichen Zeit. Ich bin nicht sicher, ob ich zuerst alle Makler zuerst und dann die Spiegeler aktualisieren sollte.
Irgendwelche Vorschläge. Sollte ich dem gleichen Verfahren folgen, upgrade zuerst alle Broker und dann alle mirrormakers. Sobald sie aktualisiert wurden, stoßen Sie die Protokolle in server.properties an. Auch wenn es scheint, dass die Art der Dokumentation das nicht impliziert: http://kafka.apache.org/documentation.html#upgrade