Atualizar o tamanho do agente de cluster do Amazon MSK - Amazon Managed Streaming for Apache Kafka
Atualizar o tamanho do agente do cluster usando o consoleAtualize o tamanho do agente do cluster usando a CLIAtualizar o tamanho de agente usando a API

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Atualizar o tamanho do agente de cluster do Amazon MSK

Você pode escalar o cluster do MSK sob demanda alterando o tamanho dos agentes sem reatribuir partições do Apache Kafka. A alteração do tamanho dos agentes oferece a flexibilidade de ajustar a capacidade computacional do cluster do MSK com base nas mudanças nas workloads, sem interromper a E/S do cluster. O Amazon MSK usa o mesmo tipo de agente para todos os agentes em um determinado cluster.

Você pode atualizar o tamanho do agente de cluster de M5 ou T3 para M7g, de T3 para M5 ou de M7g para M5.

nota

Você não pode migrar de um agente maior para outro menor. Por exemplo, de M7G.large para T3.small.

Você pode usar apenas os tamanhos M7g como agentes Express.

Este tópico descreve como atualizar o tamanho do agente do cluster do MSK.

Esteja ciente de que migrar para um agente de tamanho menor pode diminuir a performance e reduzir o throughput máximo possível por agente. A migração para um agente de tamanho maior pode aumentar o desempenho, mas pode custar mais.

A atualização do tamanho do agente ocorre de maneira contínua enquanto o cluster está ativo e em execução. Isso significa que o Amazon MSK retira um agente por vez para realizar a atualização do seu tamanho. Para obter informações sobre como tornar um cluster altamente disponível durante uma atualização de tamanho de agente, consulte Criar clusters altamente disponíveis. Para reduzir ainda mais qualquer possível impacto sobre a produtividade, você pode realizar a atualização do tamanho do agente durante um período de baixo tráfego.

Durante uma atualização do tamanho do agente, você pode continuar produzindo e consumindo dados. No entanto, é necessário esperar até que a atualização seja concluída para poder reinicializar os agentes ou invocar qualquer uma das operações de atualização listadas nas operações do Amazon MSK.

Se você quiser atualizar o cluster para um tamanho de agente menor, recomendamos que experimente primeiro a atualização em um cluster de teste para ver como isso afetará o cenário.

Importante

Você não poderá atualizar um cluster para um tamanho de agente menor se o número de partições por agente exceder o número máximo especificado em Dimensione seu cluster adequadamente: número de partições por agente Standard.

Atualize o tamanho do agente de cluster Amazon MSK usando o Console de gerenciamento da AWS

Esse processo mostra como atualizar o tamanho do agente de cluster Amazon MSK usando o Console de gerenciamento da AWS

  1. Faça login no Console de gerenciamento da AWS e abra o console Amazon MSK em https://console.aws.amazon.com/msk/casa? region=us-east-1#/home/.

  2. Escolha o cluster do MSK para o qual deseja atualizar o tamanho do agente.

  3. Na página de detalhes do cluster, encontre a seção Resumo dos agentes e escolha Editar tamanho do agente.

  4. Selecione o tamanho do agente desejado na lista.

  5. Salve as alterações.

Atualize o tamanho do agente de cluster Amazon MSK usando o AWS CLI

Execute o comando a seguir, substituindo ClusterArn pelo nome do recurso da Amazon (ARN) que você obteve quando criou o cluster. Se você não tiver o ARN do cluster, poderá encontrá-lo listando todos os clusters. Para obter mais informações, consulte Listar clusters do Amazon MSK.

  1. Current-Cluster-VersionSubstitua pela versão atual do cluster e TargetType pelo novo tamanho que você deseja que os corretores tenham. Para saber mais sobre os tamanhos de agentes, consulte Tipos de agentes do Amazon MSK.

    aws kafka update-broker-type --cluster-arn ClusterArn --current-version Current-Cluster-Version --target-instance-type TargetType

    Veja a seguir um exemplo de como usar esse comando:

    aws kafka update-broker-type --cluster-arn "arn:aws:kafka:us-east-1:0123456789012:cluster/exampleName/abcd1234-0123-abcd-5678-1234abcd-1" --current-version "K1X5R6FKA87" --target-instance-type kafka.m5.large

    A saída desse comando é semelhante ao seguinte JSON de exemplo.

    {
    "ClusterArn": "arn:aws:kafka:us-east-1:0123456789012:cluster/exampleName/abcd1234-0123-abcd-5678-1234abcd-1",
    "ClusterOperationArn": "arn:aws:kafka:us-east-1:012345678012:cluster-operation/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2/0123abcd-abcd-4f7f-1234-9876543210ef"
}

  2. Para obter o resultado da update-broker-type operação, execute o comando a seguir, ClusterOperationArn substituindo-o pelo ARN obtido na saída do update-broker-type comando.

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

    A saída desse comando describe-cluster-operation é semelhante ao seguinte JSON de exemplo.

    {
  "ClusterOperationInfo": {
    "ClientRequestId": "982168a3-939f-11e9-8a62-538df00285db",
    "ClusterArn": "arn:aws:kafka:us-east-1:0123456789012:cluster/exampleName/abcd1234-0123-abcd-5678-1234abcd-1",
    "CreationTime": "2021-01-09T02:24:22.198000+00:00",
    "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": "UPDATE_BROKER_TYPE",
    "SourceClusterInfo": {
      "InstanceType": "t3.small"
    },
    "TargetClusterInfo": {
      "InstanceType": "m5.large"
    }
  }
}

    Se OperationState tiver o valor UPDATE_IN_PROGRESS, aguarde um pouco e execute o comando describe-cluster-operation novamente.

Atualizar o tamanho de agente usando a API

Para atualizar o tamanho do broker usando a API, consulte UpdateBrokerType.

Você pode usar UpdateBrokerType para atualizar o tamanho do agente de cluster de M5 ou T3 para M7g ou de M7g para M5.