Expansión de un MSK clúster de Amazon - Transmisión gestionada 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.

Expansión de un MSK clúster de Amazon

Utilice esta MSK operación de Amazon cuando desee aumentar el número de corredores en su MSK clúster. Para ampliar un clúster, asegúrese de que está en el estado ACTIVE.

importante

Si quieres expandir un MSK clúster, asegúrate de usar esta MSK operación de Amazon. No intente agregar agentes a un clúster sin usar esta operación.

Para obtener información acerca de cómo volver a equilibrar particiones después de agregar agentes a un clúster, consulte Reasignar particiones.

Expandir un clúster mediante el AWS Management Console

  1. Abre la MSK consola de Amazon enhttps://console.aws.amazon.com/msk/.

  2. Elija el MSK clúster cuyo número de corredores desee aumentar.

  3. En la página de detalles del clúster, elija el botón Editar situado junto al encabezado Detalles de agente de clúster.

  4. Introduzca el número de agentes que quiere que tenga el clúster por zona de disponibilidad y, luego, elija Guardar cambios.

Expansión de un clúster mediante el AWS CLI

  1. Ejecute el siguiente comando, sustituyendo ClusterArn con el nombre de recurso de Amazon (ARN) que obtuviste al crear tu clúster. Si no tiene el ARN correspondiente a su clúster, puede encontrarlo enumerando todos los clústeres. Para obtener más información, consulte Listado de MSK clústeres de Amazon.

    Reemplazar Current-Cluster-Version con la versión actual del clúster.

    importante

    Las versiones de clúster no son enteros simples. Para encontrar la versión actual del clúster, utilice la DescribeClusteroperación o el comando AWS CLI describe-cluster. Un ejemplo de ID de versión es KTVPDKIKX0DER.

    La Target-Number-of-Brokers El parámetro representa el número total de nodos intermediarios que desea que tenga el clúster cuando la operación se complete correctamente. El valor que especifique para Target-Number-of-Brokers debe ser un número entero superior al número actual de corredores del clúster. También debe ser un múltiplo del número de zonas de disponibilidad.

    aws kafka update-broker-count --cluster-arn ClusterArn --current-version Current-Cluster-Version --target-number-of-broker-nodes Target-Number-of-Brokers

    El resultado de esta update-broker-count operación es similar al siguienteJSON.

    { "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" }
  2. Para obtener el resultado de la update-broker-count operación, ejecute el siguiente comando, sustituyendo ClusterOperationArn con el ARN que obtuvo en el resultado del update-broker-count comando.

    aws kafka describe-cluster-operation --cluster-operation-arn ClusterOperationArn

    El resultado de este describe-cluster-operation comando es similar al del siguiente JSON ejemplo.

    { "ClusterOperationInfo": { "ClientRequestId": "c0b7af47-8591-45b5-9c0c-909a1a2c99ea", "ClusterArn": "arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2", "CreationTime": "2019-09-25T23:48:04.794Z", "OperationArn": "arn:aws:kafka:us-east-1:012345678012:cluster-operation/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2/0123abcd-abcd-4f7f-1234-9876543210ef", "OperationState": "UPDATE_COMPLETE", "OperationType": "INCREASE_BROKER_COUNT", "SourceClusterInfo": { "NumberOfBrokerNodes": 9 }, "TargetClusterInfo": { "NumberOfBrokerNodes": 12 } } }

    En esta salida, OperationType es INCREASE_BROKER_COUNT. Si OperationState tiene el valor UPDATE_IN_PROGRESS, espere un rato y vuelva a ejecutar el comando describe-cluster-operation.

Expansión de un clúster mediante la API

Para aumentar el número de corredores de un clúster mediante elAPI, consulte UpdateBrokerCount.