Als ich Schema-Registrierungsserver verwendet habe, fand ich, dass ich das Schema im selben Thema nicht mehr ändern konnte. Aber ohne Schema-Registrierung hat jeder Datensatz sein eigenes Schema, so dass es einfach ist, das Schema jederzeit zu ändern.Sollte Kafka Schema Registry Server verwenden
Wie kann ich das Schema ändern, wenn ich den Schema-Registrierungsserver verwende?
Sie können Schemas ändern, die in der Konfluent-Schema-Registrierung gespeichert sind. Es ist nur so, dass die Standardkonfiguration die Abwärtskompatibilität erzwingt. Sie können diese Kompatibilität Config ändern Sie die folgenden Parameter verwendet:
avro.compatibility.level
Die Avro Kompatibilität Typ. Gültige Werte sind: none (neues Schema kann ein beliebiges gültiges Avro-Schema sein), backward (neues Schema kann vom neuesten registrierten Schema erzeugte Daten lesen), backward_transitive (neues Schema kann Daten lesen, die von allen zuvor registrierten Schemas erzeugt wurden), forward (letztes registriertes Schema kann die vom neuen Schema erzeugten Daten lesen), forward_transitive (alle zuvor registrierten Schemas können die vom neuen Schema erzeugten Daten lesen), full (neues Schema ist rückwärts und vorwärts kompatibel mit dem neuesten registrierten Schema), full_transitive (neues Schema ist rückwärts und vorwärts kompatibel) mit allen zuvor registrierten Schemas)
Typ: String Default: "rückwärts" Wichtigkeit: hoch