View a markdown version of this page

Steady-State-Rebalancing für Amazon MSK-Cluster - Amazon Managed Streaming für Apache Kafka

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.

Steady-State-Rebalancing für Amazon MSK-Cluster

Anmerkung

Ab dem 18. Juni 2026 ist Intelligent Rebalancing für alle von MSK bereitgestellten Cluster mit Express-Brokern verfügbar. Dazu gehören Express-Cluster, die vor der Einführung der intelligenten Rebalancing-Funktion im November 2025 erstellt wurden. Für Cluster, die vor dem 20. November 2025 erstellt wurden, ist Intelligent Rebalancing verfügbar, wobei der Rebalancing-Status auf „Angehalten“ gesetzt ist. Um diese Funktion für Ihre vorhandenen Cluster zu aktivieren, setzen Sie den Rebalancing-Status mithilfe der Amazon MSK-Konsole oder des SDK auf Aktiv. AWS CLI Detaillierte Anweisungen finden Sie unter Stabile Neugewichtung.

Steady State Rebalancing ist Teil der intelligenten Rebalancing-Funktion, die standardmäßig für alle neuen MSK bereitgestellten Cluster mit Express-Brokern aktiviert ist. Wenn Sie Ihre Cluster nach oben oder unten skalieren, übernimmt Amazon MSK automatisch die Partitionsverwaltung, indem es Partitionen an neue Broker verteilt und Partitionen von Brokern verschiebt, die entfernt werden müssen. Um eine optimale Verteilung der Arbeitslast auf die Makler zu gewährleisten, verwendet Intelligent Rebalancing die Best Practices von Amazon MSK, um Schwellenwerte für die automatische Initiierung des Rebalancing für Ihre Broker festzulegen.

Sie können den Steady-State-Rebalancing bei Bedarf anhalten und wieder aufnehmen. Beim Steady-State-Rebalancing wird Ihr Cluster kontinuierlich überwacht und es werden folgende Aktionen ausgeführt:

  • Verfolgt die Nutzung von Broker-Ressourcen (CPU, Netzwerk, Speicher).

  • Passt die Partitionsplatzierung automatisch an, ohne die Datenverfügbarkeit zu beeinträchtigen.

  • Schließt Neuausgleichsvorgänge bei Express-Brokern bis zu 180-mal schneller ab als bei Standard-Brokern.

  • Hält die Cluster-Leistung aufrecht.

Themen
    Pause and resume steady state rebalancing in AWS-Managementkonsole

    1. Öffnen Sie die Amazon MSK-Konsole unter? https://console.aws.amazon.com/msk/home region=us-east-1#/home/.

    2. Wählen Sie auf der Cluster-Seite einen Cluster aus. Express-based Informationen zum Erstellen eines bereitgestellten Express-based Clusters finden Sie unterSchritt 1: Erstellen Sie einen von MSK bereitgestellten Cluster.

    3. Überprüfen Sie auf der Cluster-Detailseite den Status Intelligent Rebalancing. Wenn der Status „Angehalten“ lautet, führen Sie die Schritte 4 bis 5 aus, um ihn zu aktivieren.

    4. Wählen Sie in der Dropdownliste Aktionen die Option Intelligentes Rebalancing bearbeiten aus.

    5. Gehen Sie auf der Seite Intelligentes Rebalancing bearbeiten wie folgt vor:

      1. Wählen Sie Aktiv.

      2. Wählen Sie Änderungen speichern aus.

    Pause and resume steady state rebalancing using AWS CLI

    Um den Rebalancing-Status eines Clusters auf die ACTIVE Verwendung von festzulegen AWS CLI, verwenden Sie den Befehl update-rebalancing, wie im folgenden Beispiel gezeigt. Geben Sie in diesem Befehl den Status mit dem Parameter an. rebalancing

    aws msk update-rebalancing --cluster-arn arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ef-ghij-klmnopqrstuv-1 --current-version ABCDEF1GHIJK0L --rebalancing "{\"Rebalancing\":{\"Status\":\"ACTIVE\"}}"
    Pause and resume steady state rebalancing using AWS SDK

    Sie können den Rebalancing-Status eines Clusters auch mithilfe der UpdateRebalancingRequestAPI festlegen, um die Anzahl der Broker programmgesteuert zu ändern. Die folgenden Beispiele zeigen, wie der Rebalancing-Status auf und gesetzt wird. ACTIVE PAUSED

    final UpdateRebalancingRequest updateRebalancingRequest = new UpdateRebalancingRequest()
    .withClusterArn(arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ef-ghij-klmnopqrstuv-1)
    .withCurrentVersion(ABCDEF1GHIJK0L)
    .withRebalancing(new Rebalancing().withStatus("ACTIVE"));
    final UpdateRebalancingRequest updateRebalancingRequest = new UpdateRebalancingRequest()
    .withClusterArn(arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ef-ghij-klmnopqrstuv-1)
    .withCurrentVersion(ABCDEF1GHIJK0L)
    .withRebalancing(new Rebalancing().withStatus("PAUSED"));