Ist kafka consumer 0.9 abwärtskompatibel?

Gemäß der Dokumentation von Kafka 0.9.0 können Sie den neuen Benutzer nicht zum Lesen verwenden Daten von 0.8.x-Brokern. Der Grund ist folgender:

  

0.9.0.0 hat eine Inter-Broker-Protokolländerung gegenüber früheren Versionen.

Nein. Im Allgemeinen wird empfohlen, Broker vor Clients zu aktualisieren, da Broker auf Abwärtskompatibilität abzielen. Der 0.9-Broker wird sowohl mit den Consumer-APIs von 0.8 Consumer als auch 0.9 arbeiten, aber nicht umgekehrt.

Basierend auf dieser Kunden-Client Re-Design Wiki-Seite, die zitiert,

  

Dies würde einige signifikante Änderungen an den Consumer-APIs * erfordern , daher möchten wir Feedback zu dem Vorschlag unserer Community sammeln. Da die Liste der Änderungen nicht klein ist, würden wir gerne verstehen, ob einige Funktionen gegenüber anderen bevorzugt sind und, noch wichtiger, wenn einige Funktionen überhaupt nicht benötigt werden.

* Betonung meiner.

Ich habe nirgendwo ausdrücklich festgestellt, dass es keine Kompatibilität gibt. Aber unter Verwendung dieses Zitats und der Tatsache, dass der Produzent in 0.8 mit dem Produzenten in 0.7 nicht kompatibel war, nehme ich an, dass sie nicht kompatibel sind.

Ich hatte kürzlich ein ähnliches Problem, wo ich in meiner Bewerbung von kafka 0.9 lesen musste und dann zurück zu kafka 0.8 schreiben musste. Ich habe kafka client 0.9 folgendermaßen benutzt.

Consumer-Konfiguration

Herstellerkonfiguration

Hoffe, das hilft.

Es sieht so aus, dass in kafka 0.9.0 die Abwärtskompatibilität eingebaut ist. Überprüfen Sie Ссылка

Zitat aus der Dokumentation

  

0.9.0.0 weist potenzielle Änderungen beim Brechen (überprüfen Sie vor dem Aktualisieren auf) und eine Inter-Broker-Protokolländerung von früheren Versionen auf. Für ein rollendes Upgrade:

     

• Aktualisieren Sie die Datei server.properties auf allen Brokern und fügen Sie Folgendes hinzu   Eigenschaft: inter.broker.protocol.version = 0.8.2.X
  
• Aktualisieren Sie die Broker.   Dies kann zu einem bestimmten Zeitpunkt durch einen Broker erledigt werden,   den Code aktualisieren und neu starten.
  
• Sobald der gesamte Cluster ist   aktualisiert, stoßen Sie die Protokollversion durch Bearbeiten an   inter.broker.protocol.version und setze es auf 0.9.0.0.
  
• Starten Sie das Programm neu   Broker nacheinander, damit die neue Protokollversion in Kraft tritt