View a markdown version of this page

Rééquilibrage permanent pour les clusters Amazon MSK - Amazon Managed Streaming for Apache Kafka

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Rééquilibrage permanent pour les clusters Amazon MSK

Note

À compter du 18 juin 2026, le rééquilibrage intelligent est disponible pour tous les clusters provisionnés par MSK auprès des courtiers Express. Cela inclut les clusters Express créés avant le lancement de la fonction de rééquilibrage intelligent en novembre 2025. Pour les clusters créés avant le 20 novembre 2025, le rééquilibrage intelligent est disponible avec l'état de rééquilibrage défini sur Suspendu. Pour activer cette fonctionnalité pour vos clusters existants, définissez le statut de rééquilibrage sur Actif à l'aide de la console Amazon MSK ou du AWS CLI SDK. Pour obtenir des instructions, veuillez consulter Rééquilibrage en régime permanent.

Le rééquilibrage en régime permanent fait partie de la fonction de rééquilibrage intelligent, qui est activée par défaut pour tous les nouveaux clusters provisionnés par MSK auprès d'Express Brokers. Lorsque vous augmentez ou diminuez la taille de vos clusters, Amazon MSK gère automatiquement la gestion des partitions en distribuant les partitions aux nouveaux courtiers et en déplaçant les partitions des courtiers en attente de suppression. Pour garantir une répartition optimale de la charge de travail entre les courtiers, le rééquilibrage intelligent utilise les meilleures pratiques d'Amazon MSK pour déterminer les seuils permettant de lancer automatiquement le rééquilibrage pour vos courtiers.

Vous pouvez faire une pause et reprendre le rééquilibrage en régime permanent en cas de besoin. Le rééquilibrage en régime permanent surveille en permanence votre cluster et effectue les opérations suivantes :

  • Suit l'utilisation des ressources du courtier (processeur, réseau, stockage).

  • Ajuste automatiquement le placement des partitions sans aucun impact sur la disponibilité des données.

  • Effectue les opérations de rééquilibrage jusqu'à 180 fois plus rapidement pour les courtiers Express que pour les courtiers standard.

  • Maintient les performances du cluster.

Rubriques
    Pause and resume steady state rebalancing in AWS Management Console

    1. Ouvrez la console Amazon MSK à https://console.aws.amazon.com/msk/home l'adresse ? region=us-east-1#/home/.

    2. Sur la page Clusters, choisissez un Express-based cluster. Pour plus d'informations sur la création d'un Express-based cluster provisionné, consultezÉtape 1 : créer un cluster provisionné MSK.

    3. Sur la page détaillée du cluster, vérifiez l'état du rééquilibrage intelligent. Si le statut est Suspendu, suivez les étapes 4 et 5 pour l'activer.

    4. Dans la liste déroulante Actions, choisissez Modifier le rééquilibrage intelligent.

    5. Sur la page Modifier le rééquilibrage intelligent, procédez comme suit :

      1. Choisissez Active.

      2. Sélectionnez Enregistrer les modifications.

    Pause and resume steady state rebalancing using AWS CLI

    Pour définir l'état de rééquilibrage d'un cluster à ACTIVE l'aide de AWS CLI, utilisez la commande update-rebalancing, comme indiqué dans l'exemple suivant. Dans cette commande, spécifiez le statut à l'aide du rebalancing paramètre.

    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

    Vous pouvez également définir l'état de rééquilibrage d'un cluster à l'aide de l'UpdateRebalancingRequestAPI pour modifier par programmation le nombre de courtiers. Les exemples suivants montrent comment définir l'état de rééquilibrage sur ACTIVE etPAUSED.

    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"));