View a markdown version of this page

Ribilanciamento dello stato stazionario per i cluster Amazon MSK - Amazon Managed Streaming per Apache Kafka

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Ribilanciamento dello stato stazionario per i cluster Amazon MSK

Nota

A partire dal 18 giugno 2026, Intelligent Rebalancing è disponibile per tutti i cluster MSK Provisioned con broker Express. Ciò include i cluster Express creati prima del lancio della funzionalità di ribilanciamento intelligente nel novembre 2025. Per i cluster creati prima del 20 novembre 2025, il ribilanciamento intelligente è disponibile con lo stato di ribilanciamento impostato su In pausa. Per abilitare questa funzionalità per i cluster esistenti, imposta lo stato di ribilanciamento su Attivo utilizzando la console Amazon MSK o l'SDK. AWS CLI Per istruzioni, consulta Ribilanciamento allo stato stazionario.

Il ribilanciamento allo stato stazionario fa parte della funzionalità di ribilanciamento intelligente, attivata di default per tutti i nuovi cluster MSK Provisioned con broker Express. Man mano che aumenti o riduci i cluster, Amazon MSK gestisce automaticamente la gestione delle partizioni distribuendo le partizioni a nuovi broker e spostando le partizioni dai broker da rimuovere. Per garantire una distribuzione ottimale del carico di lavoro tra i broker, il ribilanciamento intelligente utilizza le best practice di Amazon MSK per determinare le soglie per l'avvio automatico del ribilanciamento per i broker.

Puoi mettere in pausa e riprendere il riequilibrio allo stato stazionario quando necessario. Il ribilanciamento dello stato stazionario monitora continuamente il cluster ed esegue le seguenti operazioni:

  • Tiene traccia dell'utilizzo delle risorse del broker (CPU, rete, storage).

  • Regola automaticamente il posizionamento delle partizioni senza alcun impatto sulla disponibilità dei dati.

  • Completa le operazioni di ribilanciamento fino a 180 volte più velocemente per i broker Express rispetto ai broker Standard.

  • Mantiene le prestazioni del cluster.

Argomenti
    Pause and resume steady state rebalancing in Console di gestione AWS

    1. Aprire la console Amazon MSK all'indirizzohttps://console.aws.amazon.com/msk/home? region=us-east-1#/home/.

    2. Nella pagina Cluster, scegli un cluster. Express-based Per informazioni sulla creazione di un Express-based cluster assegnato, vedere. Fase 1: creare un cluster MSK Provisioned

    3. Nella pagina dei dettagli del cluster, verifica lo stato del ribilanciamento intelligente. Se lo stato è In pausa, segui i passaggi 4—5 per abilitarlo.

    4. Nell'elenco a discesa Azioni, scegli Modifica ribilanciamento intelligente.

    5. Nella pagina Modifica ribilanciamento intelligente, procedi come segue:

      1. Scegliete Attivo.

      2. Scegli Save changes (Salva modifiche).

    Pause and resume steady state rebalancing using AWS CLI

    Per impostare lo stato di ribilanciamento di un cluster sull'ACTIVEutilizzo di AWS CLI, utilizzate il comando update-rebalancing, come illustrato nell'esempio seguente. In questo comando, specificate lo stato con il parametro. 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

    È inoltre possibile impostare lo stato di ribilanciamento di un cluster utilizzando l'UpdateRebalancingRequestAPI per modificare a livello di codice il conteggio dei broker. Gli esempi seguenti mostrano come impostare lo stato di ribilanciamento su e. 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"));