View a markdown version of this page

Reequilibrio de estado estacionario para clústeres de Amazon MSK - Transmisión administrada de Amazon para Apache Kafka

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Reequilibrio de estado estacionario para clústeres de Amazon MSK

nota

A partir del 18 de junio de 2026, el reequilibrio inteligente estará disponible para todos los clústeres aprovisionados de MSK con agentes Express. Esto incluye los clústeres Express creados antes del lanzamiento de la función de reequilibrio inteligente en noviembre de 2025. Para los clústeres creados antes del 20 de noviembre de 2025, el reequilibrio inteligente está disponible con el estado de reequilibrio establecido en En pausa. Para habilitar esta función en sus clústeres existentes, establezca el estado de reequilibrio en Activo mediante la consola o el SDK de Amazon MSK. AWS CLI Para obtener instrucciones, consulte Reequilibrio en estado estacionario.

El reequilibrio en estado estable forma parte de la función de reequilibrio inteligente, que está activada de forma predeterminada para todos los clústeres nuevos aprovisionados por MSK con los agentes de Express. A medida que amplía o reduce los clústeres, Amazon MSK gestiona automáticamente la administración de las particiones distribuyéndolas a nuevos agentes y trasladándolas de los agentes para su eliminación. Para garantizar una distribución óptima de la carga de trabajo entre los corredores, el reequilibrio inteligente utiliza las mejores prácticas de Amazon MSK para determinar los umbrales para iniciar automáticamente el reequilibrio para sus corredores.

Puede pausar y reanudar el reequilibrio en estado estable cuando sea necesario. El reequilibrio en estado estacionario monitorea continuamente el clúster y hace lo siguiente:

  • Realiza un seguimiento del uso de los recursos del bróker (CPU, red, almacenamiento).

  • Ajusta la ubicación de las particiones automáticamente sin que ello afecte a la disponibilidad de los datos.

  • Completa las operaciones de reequilibrio hasta 180 veces más rápido para los corredores Express en comparación con los corredores estándar.

  • Mantiene el rendimiento del clúster.

Temas
    Pause and resume steady state rebalancing in Consola de administración de AWS

    1. Abra la consola Amazon MSK en? https://console.aws.amazon.com/msk/home region=us-east-1#/home/.

    2. En la página Clústeres, elija un clúster. Express-based Para obtener información sobre la creación de un Express-based clúster aprovisionado, consultePaso 1: Creación de un clúster de MSK aprovisionado.

    3. En la página de detalles del clúster, compruebe el estado del reequilibrio inteligente. Si el estado es En pausa, siga los pasos 4 a 5 para activarlo.

    4. En la lista desplegable Acciones, selecciona Editar el reequilibrio inteligente.

    5. En la página Editar el reequilibrio inteligente, haga lo siguiente:

      1. Elija Activar.

      2. Seleccione Save changes (Guardar cambios).

    Pause and resume steady state rebalancing using AWS CLI

    Para configurar el estado de reequilibrio de un clúster para que utilice el AWS CLI, ACTIVE utilice el comando update-rebalancing, como se muestra en el siguiente ejemplo. En este comando, especifique el estado con el parámetro. 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

    También puede establecer el estado de reequilibrio de un clúster mediante la UpdateRebalancingRequestAPI para modificar mediante programación el recuento de agentes. Los siguientes ejemplos muestran cómo establecer el estado de reequilibrio en y. 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"));