Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
Aktualisieren Sie die Apache Kafka-Version
Sie können einen vorhandenen MSK-Cluster auf eine neuere Version von Apache Kafka aktualisieren.
Anmerkung
-
Sie können einen vorhandenen MSK-Cluster nicht von einer ZooKeeper Apache Kafka-Version auf eine neuere Version aktualisieren, die Modus verwendet oder erfordert. KRaft Um Ihren Cluster zu aktualisieren, erstellen Sie stattdessen einen neuen MSK-Cluster mit einer KRaft unterstützten Kafka-Version und migrieren Sie Ihre Daten und Workloads aus dem alten Cluster.
-
Amazon MSK aktualisiert nur die Serversoftware. Ihre Clients werden nicht aktualisiert.
-
Sie können einen vorhandenen MSK-Cluster nicht auf eine ältere Version von Apache Kafka herunterstufen.
Wenn Sie die Apache Kafka-Version eines MSK-Clusters aktualisieren, überprüfen Sie auch Ihre clientseitige Software, um sicherzustellen, dass Sie mit ihrer Version die Funktionen der neuen Apache Kafka-Version des Clusters nutzen können.
Informationen darüber, wie Sie einen Cluster während eines Upgrades hochverfügbar machen können, finden Sie unter. Erstellen hochverfügbarer Cluster
Aktualisieren Sie die Apache Kafka-Version mit dem AWS Management Console
Öffnen Sie die Amazon-MSK-Konsole unter https://console.aws.amazon.com/msk/
. -
Wählen Sie in der Navigationsleiste die Region aus, in der Sie den MSK-Cluster erstellt haben.
-
Wählen Sie den MSK-Cluster aus, den Sie aktualisieren möchten.
-
Wählen Sie auf der Registerkarte Eigenschaften im Abschnitt Apache Kafka-Version die Option Upgrade aus.
-
Gehen Sie im Abschnitt Apache Kafka-Version wie folgt vor:
-
Wählen Sie in der Dropdownliste Apache Kafka-Version auswählen die Version aus, auf die Sie ein Upgrade durchführen möchten. Wählen Sie zum Beispiel aus
3.9.x
. -
(Optional) Wählen Sie Versionskompatibilität, um die Kompatibilität zwischen der aktuellen Version Ihres Clusters und der Version, auf die Sie ein Upgrade durchführen möchten, anzuzeigen. Wählen Sie dann „Auswählen“, um fortzufahren, oder „Abbrechen“.
-
Aktivieren Sie das Kontrollkästchen Clusterkonfiguration aktualisieren, um automatisch eine neue Version der Kafka-Konfiguration anzuwenden, die mit der aktualisierten Version kompatibel ist. Dadurch wird die Kompatibilität gewährleistet und neue Funktionen oder Verbesserungen der aktualisierten Version ermöglicht. Überspringen Sie es jedoch, wenn Sie Ihre vorhandenen benutzerdefinierten Konfigurationen beibehalten möchten.
-
Wählen Sie Upgrade.
-
Aktualisieren Sie die Apache Kafka-Version mit dem AWS CLI
Führen Sie den folgenden Befehl aus und
ClusterArn
ersetzen Sie ihn durch den Amazon-Ressourcennamen (ARN), den Sie bei der Erstellung Ihres Clusters erhalten haben. Wenn Ihnen der ARN für Ihren Cluster nicht vorliegt, finden Sie ihn, indem Sie alle Cluster auflisten. Weitere Informationen finden Sie unter Amazon MSK-Cluster auflisten.aws kafka get-compatible-kafka-versions --cluster-arn
ClusterArn
Die Ausgabe dieses Befehls enthält eine Liste der Apache Kafka-Versionen, auf die Sie den Cluster aktualisieren können. Es sollte wie das folgende Beispiel aussehen.
{ "CompatibleKafkaVersions": [ { "SourceVersion": "2.2.1", "TargetVersions": [ "2.3.1", "2.4.1", "2.4.1.1", "2.5.1" ] } ] }
-
Führen Sie den folgenden Befehl aus und
ClusterArn
ersetzen Sie ihn durch den Amazon-Ressourcennamen (ARN), den Sie bei der Erstellung Ihres Clusters erhalten haben. Wenn Ihnen der ARN für Ihren Cluster nicht vorliegt, finden Sie ihn, indem Sie alle Cluster auflisten. Weitere Informationen finden Sie unter Amazon MSK-Cluster auflisten.Current-Cluster-Version
Ersetzen Sie durch die aktuelle Version des Clusters. DennTargetVersion
Sie können eine der Zielversionen aus der Ausgabe des vorherigen Befehls angeben.Wichtig
Cluster-Versionen sind keine einfachen Ganzzahlen. Verwenden Sie den Befehl DescribeClusteroperation oder describe-cluster, um die aktuelle Version des Clusters
AWS CLI zu finden. KTVPDKIKX0DER
ist ein Beispiel für eine Version.aws kafka update-cluster-kafka-version --cluster-arn
ClusterArn
--current-versionCurrent-Cluster-Version
--target-kafka-versionTargetVersion
Die Ausgabe des Befehls sieht wie das folgende JSON aus.
{ "ClusterArn": "arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2", "ClusterOperationArn": "arn:aws:kafka:us-east-1:012345678012:cluster-operation/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2/0123abcd-abcd-4f7f-1234-9876543210ef" }
-
Um das Ergebnis des
update-cluster-kafka-version
Vorgangs zu erhalten, führen Sie den folgenden Befehl aus undClusterOperationArn
ersetzen Sie ihn durch den ARN, den Sie in der Ausgabe desupdate-cluster-kafka-version
Befehls erhalten haben.aws kafka describe-cluster-operation --cluster-operation-arn
ClusterOperationArn
Die Ausgabe dieses
describe-cluster-operation
-Befehls sieht wie das folgende JSON-Beispiel aus.{ "ClusterOperationInfo": { "ClientRequestId": "62cd41d2-1206-4ebf-85a8-dbb2ba0fe259", "ClusterArn": "arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2", "CreationTime": "2021-03-11T20:34:59.648000+00:00", "OperationArn": "arn:aws:kafka:us-east-1:012345678012:cluster-operation/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2/0123abcd-abcd-4f7f-1234-9876543210ef", "OperationState": "UPDATE_IN_PROGRESS", "OperationSteps": [ { "StepInfo": { "StepStatus": "IN_PROGRESS" }, "StepName": "INITIALIZE_UPDATE" }, { "StepInfo": { "StepStatus": "PENDING" }, "StepName": "UPDATE_APACHE_KAFKA_BINARIES" }, { "StepInfo": { "StepStatus": "PENDING" }, "StepName": "FINALIZE_UPDATE" } ], "OperationType": "UPDATE_CLUSTER_KAFKA_VERSION", "SourceClusterInfo": { "KafkaVersion": "2.4.1" }, "TargetClusterInfo": { "KafkaVersion": "2.6.1" } } }
Wenn
OperationState
den Wert „UPDATE_IN_PROGRESS
“ aufweist, warten Sie eine Weile, bevor Sie dendescribe-cluster-operation
-Befehl erneut ausführen. Wenn der Vorgang abgeschlossen ist, erhältOperationState
den WertUPDATE_COMPLETE
. Da die Zeit, die Amazon MSK benötigt, um den Vorgang abzuschließen, unterschiedlich ist, müssen Sie dies möglicherweise wiederholt überprüfen, bis der Vorgang abgeschlossen ist.
Aktualisieren Sie die Apache Kafka-Version mithilfe der API
Rufen Sie den GetCompatibleKafkaVersionsVorgang auf, um eine Liste der Apache Kafka-Versionen abzurufen, auf die Sie den Cluster aktualisieren können.
Rufen Sie den UpdateClusterKafkaVersionVorgang auf, um den Cluster auf eine der kompatiblen Apache Kafka-Versionen zu aktualisieren.