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á. # Conceitos básicos sobre como usar o Amazon MSK Este tutorial mostra um exemplo de como criar um cluster do MSK, produzir e consumir dados e monitorar a integridade do seu cluster usando métricas. Este exemplo não representa todas as opções que você pode escolher ao criar um cluster do MSK. Em diferentes partes deste tutorial, escolhemos as opções padrão para facilitar. Isso não significa que estas são as únicas opções disponíveis para configurar um cluster do MSK ou instâncias de cliente. **Topics** + [ # Etapa 1: criar um cluster do MSK Provisioned ](create-cluster.md) + [ # Etapa 2: criar um perfil do IAM concedendo acesso para criar tópicos no cluster do Amazon MSK ](create-client-iam-role.md) + [ # Etapa 3: criar uma máquina cliente ](create-client-machine.md) + [ # Etapa 4: criar um tópico no cluster do Amazon MSK ](create-topic.md) + [ # Etapa 5: produzir e consumir dados ](produce-consume.md) + [ # Etapa 6: Use CloudWatch a Amazon para visualizar as métricas do Amazon MSK ](view-metrics.md) + [ # Etapa 7: Excluir os AWS recursos criados para este tutorial ](delete-cluster.md) # Etapa 1: criar um cluster do MSK Provisioned Nesta etapa de [Conceitos básicos sobre como usar o Amazon MSK](getting-started.md), você vai criar um cluster do MSK Provisioned. Você usa a opção **Criação rápida** no Console de gerenciamento da AWS para criar esse cluster. **Para criar um cluster Amazon MSK usando o Console de gerenciamento da AWS**Crie um cluster 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\$1/home/](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/). 1. Selecione **Criar cluster**. 1. Em **Método de criação**, deixe a opção **Criação rápida** selecionada. A opção **Criação rápida** permite criar um cluster com as configurações padrão. 1. Em **Nome do cluster**, insira um nome descritivo para o cluster. Por exemplo, .**MSKTutorialCluster** 1. Em **Propriedades gerais do cluster**, faça o seguinte: 1. Em **Tipo de cluster**, escolha **Provisionado**. 1. Selecione a **Versão do Apache Kafka** que você deseja executar nos agentes. Escolha **Exibir compatibilidade de versões** para ver uma tabela comparativa. 1. Para o **Tipo de agente**, escolha entre agentes Standard ou Express. 1. Escolha um **Tamanho de agente**. 1. Na tabela em **Todas as configurações de cluster**, copie e salve os valores das configurações a seguir, pois você precisará deles posteriormente neste tutorial: + VPC + Sub-redes + Grupos de segurança associados à VPC 1. Selecione **Criar cluster**. 1. Verifique o **Status** do cluster na página **Resumo do cluster**. O status muda de **Criando** para **Ativo** conforme o Amazon MSK provisiona o cluster. Quando o status estiver **Ativo**, você poderá se conectar ao cluster. Para obter mais informações sobre status de cluster, consulte [Entenda os estados do cluster do MSK Provisioned](msk-cluster-states.md). **Próxima etapa** [Etapa 2: criar um perfil do IAM concedendo acesso para criar tópicos no cluster do Amazon MSK](create-client-iam-role.md) # Etapa 2: criar um perfil do IAM concedendo acesso para criar tópicos no cluster do Amazon MSK Nesta etapa, você executará duas tarefas. A primeira tarefa será a criação de uma política do IAM que conceda acesso para criar tópicos no cluster e enviar dados para esses tópicos. A segunda tarefa será a criação de um perfil do IAM e a associação dessa política a ele. Em uma etapa posterior, você criará uma máquina cliente que vai assumir esse perfil e usá-lo para criar um tópico no cluster e enviar dados para esse tópico. **Para criar uma política do IAM que permita criar tópicos e gravar neles**Criar uma política do IAM. 1. Abra o console do IAM em [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/). 1. No painel de navegação, escolha **Políticas**. 1. Selecione **Criar política**. 1. Em **Editor de política**, escolha a guia **JSON** e substitua o JSON na janela do editor pelo JSON a seguir. No exemplo a seguir, substitua o seguinte: + *region*com o código de Região da AWS onde você criou seu cluster. + Exemplo de ID da conta*123456789012*, com seu Conta da AWS ID. + *MSKTutorialCluster*e*MSKTutorialCluster*/*7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14*, com o nome do seu cluster e seu ID. ------ #### [ JSON ] **** ``` { "Version":"2012-10-17", "Statement": [ { "Effect": "Allow", "Action": [ "kafka-cluster:Connect", "kafka-cluster:AlterCluster", "kafka-cluster:DescribeCluster" ], "Resource": [ "arn:aws:kafka:us-east-1:123456789012:cluster/MSKTutorialCluster/7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14" ] }, { "Effect": "Allow", "Action": [ "kafka-cluster:*Topic*", "kafka-cluster:WriteData", "kafka-cluster:ReadData" ], "Resource": [ "arn:aws:kafka:us-east-1:123456789012:topic/MSKTutorialCluster/*" ] }, { "Effect": "Allow", "Action": [ "kafka-cluster:AlterGroup", "kafka-cluster:DescribeGroup" ], "Resource": [ "arn:aws:kafka:us-east-1:123456789012:group/MSKTutorialCluster/*" ] } ] } ``` ------ Para obter instruções sobre como gravar políticas seguras, consulte [Controle de acesso do IAM](iam-access-control.md). 1. Escolha **Próximo**. 1. Na página **Revisar e criar**, faça o seguinte: 1. Em **Nome da política**, insira um nome descritivo, como **msk-tutorial-policy**. 1. Em **Permissões definidas nesta política**, revise e and/or edite as permissões definidas em sua política. 1. (Opcional) Para ajudar a identificar, organizar ou pesquisar a política, escolha **Adicionar nova tag** para adicioná-la como pares de chave-valor. Por exemplo, adicione uma tag à sua política com o par de valores-chave **Environment** e **Test**. Para obter mais informações sobre o uso de tags, consulte [Tags para AWS Identity and Access Management recursos](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) no *Guia do usuário do IAM*. 1. Selecione **Criar política**. **Para criar um perfil do IAM e associar a política a ele** 1. No painel de navegação, escolha **Perfis** e **Criar perfil**. 1. Na página **Selecionar entidade confiável**, faça o seguinte: 1. Em **Tipo de entidade confiável**, escolha **AWS service (Serviço da AWS)**. 1. Para **Serviço ou Caso de Uso**, escolha **EC2**. 1. Em **Use case** (Caso de uso), selecione **EC2**. 1. Escolha **Próximo**. 1. Na página **Adicionar permissões**, faça o seguinte: 1. Na caixa de pesquisa sob **Políticas de permissão**, insira o nome da política que você criou anteriormente para este tutorial. Depois, à esquerda do nome da política, marque a caixa de seleção. 1. (Opcional) Defina um [limite de permissões](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_boundaries.html). Esse é um atributo avançado que está disponível para perfis de serviço, mas não para perfis vinculados ao serviço. Para obter informações sobre como definir um limite de permissões, consulte [Como criar perfis e anexar políticas (console)](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_job-functions_create-policies.html) no *Guia do usuário do IAM*. 1. Escolha **Próximo**. 1. Na página **Nomear, revisar e criar**, faça o seguinte: 1. Em **Nome do perfil**, insira um nome descritivo, como **msk-tutorial-role**. **Importante** Quando nomear um perfil, observe o seguinte: Os nomes das funções devem ser exclusivos dentro de você Conta da AWS e não podem ser diferenciados por maiúsculas e minúsculas. Por exemplo, não crie dois perfis denominados **PRODROLE** e **prodrole**. Quando usado em uma política ou como parte de um ARN, o nome de perfil diferencia maiúsculas de minúsculas. No entanto, quando exibido para os clientes no console, como durante o processo de login, o nome de perfil diferencia maiúsculas de minúsculas. Não é possível editar o nome do perfil depois de criá-lo porque outras entidades podem referenciar o perfil. 1. (Opcional) Em **Descrição**, insira uma descrição para o perfil. 1. (Opcional) Para editar os casos de uso e as permissões do perfil, escolha **Etapa 1: Selecionar entidades confiáveis** ou **Etapa 2: Adicionar permissões**, depois **Editar**. 1. (Opcional) Para ajudar a identificar, organizar ou pesquisar o perfil, escolha **Adicionar nova tag** para adicioná-las como pares de chave-valor. Por exemplo, adicione uma tag ao seu perfil com o par de valores-chave **ProductManager** e **John**. Para obter mais informações sobre o uso de tags, consulte [Tags para AWS Identity and Access Management recursos](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) no *Guia do usuário do IAM*. 1. Reveja a função e escolha **Criar função**. **Próxima etapa** [Etapa 3: criar uma máquina cliente](create-client-machine.md) # Etapa 3: criar uma máquina cliente Nesta etapa de [Conceitos básicos sobre como usar o Amazon MSK](getting-started.md), você criará uma máquina cliente. Use essa máquina cliente para criar um tópico que produza e consuma dados. Para simplificar, você criará essa máquina cliente na VPC associada ao cluster do MSK para que o cliente possa se conectar facilmente ao cluster. **Como criar uma máquina cliente**Criar uma máquina cliente 1. Abra o console do Amazon EC2 em [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. No painel do console do Amazon EC2, selecione **Launch instance (Executar instância)**. 1. Em **Nome e tags**, como **Nome**, insira um nome descritivo para sua máquina cliente, assim você poderá rastreá-la com facilidade. Por exemplo, .**MSKTutorialClient** 1. Em **Imagens de aplicações e sistemas operacionais (imagem de máquina da Amazon)**, como **Imagem de máquina da Amazon (AMI)**, escolha **AMI do Amazon Linux 2 (HVM) – Kernel 5.10, tipo de volume SSD**. 1. Em **Tipo de instância**, mantenha a seleção padrão de **t2.micro**. 1. Em **Par de chaves (login)**, escolha um par de chaves existente ou crie outro. Se não precisar de um par de chaves para se conectar à instância, você pode escolher **Continuar sem um par de chaves (não recomendado)**. Para criar um novo par de chaves, faça o seguinte: 1. Selecione **Criar um par de chaves**. 1. Em **Key pair name** (Nome do par de chaves), insira **MSKKeyPair**. 1. Em **Tipo de par de chaves** e o **Formato do arquivo de chave privada**, mantenha as seleções padrão. 1. Escolha **Create key pair (Criar par de chaves)**. Se preferir, use um par de chaves existente. 1. Role a página para baixo, expanda a seção **Detalhes avançados** e faça o seguinte: 1. Em **Perfil de instância do IAM**, escolha o perfil do IAM que você deseja que a máquina cliente assuma. Se você não tiver um perfil do IAM, faça o seguinte: 1. Escolha **Criar perfil do IAM**. 1. Execute as etapas mencionadas na [Etapa 2: criar um perfil do IAM](create-client-iam-role.md). 1. Escolha **Iniciar instância**. 1. Escolha **Exibir instâncias**. Na coluna **Grupos de segurança**, escolha o grupo de segurança que está associado à sua nova instância. Copie o ID do grupo de segurança e salve-o para usar posteriormente. 1. Abra o console da Amazon VPC em [https://console.aws.amazon.com/vpc/](https://console.aws.amazon.com/vpc/). 1. No painel de navegação, escolha **Security Groups (Grupos de segurança)**. Encontre o grupo de segurança cujo ID você salvou em [Etapa 1: criar um cluster do MSK Provisioned](create-cluster.md). 1. Na guia **Regras de entrada**, selecione **Editar regras de entrada**. 1. Escolha **Adicionar regra**. 1. Na nova regra, escolha **Todo o tráfego** na coluna **Tipo**. No segundo campo da coluna **Origem**, selecione o grupo de segurança da sua máquina cliente. Esse é o grupo cujo nome você salvou após iniciar a instância da máquina cliente. 1. Selecione **Salvar regras**. Agora, o grupo de segurança do cluster poderá aceitar o tráfego proveniente do grupo de segurança da máquina cliente. **Próxima etapa** [Etapa 4: criar um tópico no cluster do Amazon MSK](create-topic.md) # Etapa 4: criar um tópico no cluster do Amazon MSK Nesta etapa de [Introdução ao uso do Amazon MSK](getting-started.md), você pode criar um tópico usando uma das duas abordagens: usar AWS ferramentas nativas com a CreateTopic API ou usar ferramentas do Apache Kafka em uma máquina AdminClient cliente. **Atenção** Ao usar AWS ferramentas com a CreateTopic API, verifique se o cluster atende aos requisitos. Para obter detalhes, consulte o [tópico Requisitos de uso APIs](https://docs.aws.amazon.com/msk/latest/developerguide/msk-topic-operations-information.html#topic-operations-requirements). **Atenção** Ao usar a AdminClient abordagem, os números de versão do Apache Kafka usados neste tutorial são apenas exemplos. Recomendamos usar a mesma versão do cliente que a versão do cluster do MSK. Uma versão mais antiga do cliente pode não ter determinados recursos e correções de erros críticos. **Topics** + [ ## Criando um tópico usando AWS ferramentas ](#create-topic-aws-tools) + [ ## Determinação da versão do cluster do MSK ](#find-msk-cluster-version) + [ ## Como criar um tópico na máquina cliente ](#create-topic-client-machine) ## Criando um tópico usando AWS ferramentas Você pode criar tópicos em seu cluster MSK usando AWS ferramentas como a AWS CLI ou AWS o AWS SDKs Management Console. Essa abordagem fornece uma maneira simplificada de gerenciar tópicos sem exigir acesso direto às ferramentas do cliente Kafka. Para obter informações detalhadas sobre a criação de tópicos usando as AWS ferramentas, consulte o [guia do desenvolvedor CreateTopic da API](https://docs.aws.amazon.com/msk/latest/developerguide/msk-create-topic.html). ## Determinação da versão do cluster do MSK 1. Abra o console do Amazon MSK em [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Na barra de navegação, escolha a região na qual você criou seu cluster do MSK. 1. Escolha o cluster do MSK. 1. Anote a versão do Apache Kafka usada no cluster. 1. Substitua as ocorrências de números de versão do Amazon MSK neste tutorial pela versão obtida na Etapa 3. ## Como criar um tópico na máquina cliente 1. **Conecte-se à sua máquina cliente.** 1. Abra o console do Amazon EC2 em [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. No painel de navegação, escolha **Instâncias**. Em seguida, marque a caixa de seleção ao lado do nome da máquina cliente que você criou em [Etapa 3: criar uma máquina cliente](create-client-machine.md). 1. Escolha **Actions (Ações)** e **Connect (Conectar-se)**. Siga as instruções no console para se conectar à sua máquina cliente. 1. **Instale o Java e configure a variável de ambiente da versão do Kafka.** 1. Instale o Java na máquina cliente executando o comando a seguir. ``` sudo yum -y install java-11 ``` 1. Armazene a [Versão do Kafka](#find-msk-cluster-version) do seu cluster do MSK na variável de ambiente, `KAFKA_VERSION`, conforme mostrado no comando a seguir. Você precisará dessas informações em toda a configuração. ``` export KAFKA_VERSION={KAFKA VERSION} ``` Por exemplo, se estiver usando a versão 3.6.0, execute o seguinte comando: ``` export KAFKA_VERSION=3.6.0 ``` 1. **Baixe e extraia o Apache Kafka.** 1. Execute o comando a seguir para fazer download do Apache Kafka. ``` wget https://archive.apache.org/dist/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz ``` **nota** A lista a seguir apresenta algumas informações alternativas de download do Kafka que você pode usar se houver algum problema. Se houver problemas de conectividade ou quiser usar um site espelho, tente usar o seletor de espelhos do Apache, como mostrado no comando a seguir. ``` wget https://www.apache.org/dyn/closer.cgi?path=/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz ``` Baixe uma versão apropriada diretamente do [site do Apache Kafka](https://kafka.apache.org/downloads). 1. Execute o comando a seguir no diretório onde você fez download do arquivo TAR na etapa anterior. ``` tar -xzf kafka_2.13-$KAFKA_VERSION.tgz ``` 1. Armazene o caminho completo no diretório recém-criado dentro da variável de ambiente `KAFKA_ROOT`. ``` export KAFKA_ROOT=$(pwd)/kafka_2.13-$KAFKA_VERSION ``` 1. **Configure a autenticação do seu cluster do MSK.** 1. [Encontre a versão mais recente](https://github.com/aws/aws-msk-iam-auth/releases/latest) da biblioteca de clientes IAM do Amazon MSK. Essa biblioteca permite que sua máquina cliente acesse o cluster do MSK usando a autenticação do IAM. 1. Usando os comandos a seguir, navegue até o diretório `$KAFKA_ROOT/libs` e baixe o arquivo JAR associado do IAM do Amazon MSK que você encontrou na etapa anterior. Certifique-se de *\$1LATEST VERSION\$1* substituir pelo número da versão real que você está baixando. ``` cd $KAFKA_ROOT/libs ``` ``` wget https://github.com/aws/aws-msk-iam-auth/releases/latest/download/aws-msk-iam-auth-{LATEST VERSION}-all.jar ``` **nota** Antes de executar qualquer comando do Kafka que interaja com seu cluster do MSK, talvez seja necessário adicionar o arquivo JAR do IAM do Amazon MSK ao seu classpath do Java. Defina a variável ​​de ambiente `CLASSPATH` como mostrado no exemplo a seguir. ``` export CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar ``` Isso define o `CLASSPATH` para a sessão inteira, disponibilizando o JAR para todos os comandos subsequentes do Kafka. 1. Acesse o diretório `$KAFKA_ROOT/config` para criar o arquivo de configuração do cliente. ``` cd $KAFKA_ROOT/config ``` 1. Copie e cole as seguintes configurações de propriedade em um novo arquivo. Salve o arquivo como **client.properties**. ``` security.protocol=SASL_SSL sasl.mechanism=AWS_MSK_IAM sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required; sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler ``` 1. **(Opcional) Ajuste o tamanho da pilha de Java para as ferramentas do Kafka.** Se houver algum problema relacionado à memória ou se estiver trabalhando com um número grande de tópicos ou partições, você poderá ajustar o tamanho da pilha do Java. Para fazer isso, defina a variável de ambiente `KAFKA_HEAP_OPTS` antes de executar os comandos do Kafka. O exemplo a seguir define o tamanho máximo e inicial da pilha como 512 megabytes. Ajuste esses valores de acordo com seus requisitos específicos e os recursos de sistema disponíveis. ``` export KAFKA_HEAP_OPTS="-Xmx512M -Xms512M" ``` 1. **Obtenha as informações de conexão do seu cluster.** 1. Abra o console do Amazon MSK em [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Aguarde até que o status do seu cluster esteja **Ativo**. Isso pode demorar vários minutos. Depois que o status ficar **Ativo**, escolha o nome do cluster. Isso levará você a uma página com o resumo do cluster. 1. Escolha **Exibir informações do cliente**. 1. Copie a string de conexão para o endpoint privado. Você receberá três endpoints para cada um dos agentes. Armazene uma dessas cadeias de conexão na variável de ambiente `BOOTSTRAP_SERVER`, como mostrado no comando a seguir. **Substitua pelo valor real da cadeia de conexão. ``` export BOOTSTRAP_SERVER= ``` 1. **Execute o comando a seguir para criar o tópico.** ``` $KAFKA_ROOT/bin/kafka-topics.sh --create --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties --replication-factor 3 --partitions 1 --topic MSKTutorialTopic ``` Se você receber `NoSuchFileException` para o arquivo `client.properties`, confira se esse arquivo consta no diretório de trabalho atual dentro do diretório bin do Kafka. **nota** Se preferir não definir a variável de ambiente `CLASSPATH` para a sessão inteira, como alternativa você poderá prefixar cada comando do Kafka com a variável `CLASSPATH`. Essa abordagem aplica o classpath somente a esse comando específico. ``` CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar \ $KAFKA_ROOT/bin/kafka-topics.sh --create \ --bootstrap-server $BOOTSTRAP_SERVER \ --command-config $KAFKA_ROOT/config/client.properties \ --replication-factor 3 \ --partitions 1 \ --topic MSKTutorialTopic ``` 1. **(Opcional) Verifique se o cluster foi criado com êxito.** 1. Se o comando tiver êxito, a seguinte mensagem será exibida: `Created topic MSKTutorialTopic.` 1. Liste todos os tópicos para confirmar que seu tópico existe. ``` $KAFKA_ROOT/bin/kafka-topics.sh --list --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties ``` Se o comando falhar ou se houver um erro, consulte [Solução de problemas para o cluster do Amazon MSK](troubleshooting.md) para saber mais sobre solução de problemas. 1. **(Opcional) Exclua as variáveis de ambiente que você usou neste tutorial.** Se quiser manter as variáveis de ambiente para as próximas etapas deste tutorial, ignore esta etapa. Caso contrário, você pode cancelar a definição dessas variáveis, como mostrado no exemplo a seguir. ``` unset KAFKA_VERSION KAFKA_ROOT BOOTSTRAP_SERVER CLASSPATH KAFKA_HEAP_OPTS ``` **Próxima etapa** [Etapa 5: produzir e consumir dados](produce-consume.md) # Etapa 5: produzir e consumir dados Nesta etapa de [Conceitos básicos sobre como usar o Amazon MSK](getting-started.md), você produzirá e consumirá dados. **Como produzir e consumir mensagens**Como produzir e consumir mensagens 1. Execute o comando a seguir para iniciar um produtor de console. ``` $KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic ``` 1. Insira a mensagem que desejar e pressione **Enter**. Repita esta etapa duas ou três vezes. Toda vez que você inserir uma linha e pressionar **Enter**, essa linha será enviada para o cluster do Apache Kafka como uma mensagem separada. 1. Mantenha a conexão com a máquina cliente aberta e abra uma segunda conexão separada com esse computador em uma nova janela. Como essa é uma nova sessão, novamente defina as variáveis de ambiente `KAFKA_ROOT` e `BOOTSTRAP_SERVER`. Para mais informações sobre como configurar as variáveis de ambiente, consulte [Como criar um tópico na máquina cliente](create-topic.md#create-topic-client-machine). 1. Execute o comando a seguir com sua segunda cadeia de conexão à máquina cliente para criar um consumidor no console. ``` $KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning ``` Você deve começar a ver as mensagens inseridas anteriormente quando usou o comando do produtor do console. 1. Insira mais mensagens na janela do produtor e observe-as aparecerem na janela do consumidor. **Próxima etapa** [Etapa 6: Use CloudWatch a Amazon para visualizar as métricas do Amazon MSK](view-metrics.md) # Etapa 6: Use CloudWatch a Amazon para visualizar as métricas do Amazon MSK Nesta etapa de [Introdução ao uso do Amazon MSK](getting-started.md), você analisa as métricas do Amazon MSK na Amazon. CloudWatch **Para visualizar as métricas do Amazon MSK em CloudWatch**Exibir métricas em CloudWatch 1. Abra o CloudWatch console em [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/). 1. No painel de navegação, selecione **Métricas**. 1. Escolha a guia **All metrics (Todas as métricas)** e escolha **AWS/Kafka**. 1. Para visualizar métricas no nível de agente, escolha **Broker ID, Cluster Name (ID do agente, Nome do cluster)**. Para métricas no nível de cluster, escolha **Cluster Name (Nome do cluster)**. 1. (Opcional) No painel gráfico, selecione uma estatística e um período de tempo e, em seguida, crie um CloudWatch alarme usando essas configurações. **Próxima etapa** [Etapa 7: Excluir os AWS recursos criados para este tutorial](delete-cluster.md) # Etapa 7: Excluir os AWS recursos criados para este tutorial Na etapa final de [Conceitos básicos sobre como usar o Amazon MSK](getting-started.md), você exclui o cluster do MSK e a máquina cliente que criou para este tutorial. **Para excluir os recursos usando o Console de gerenciamento da AWS**Exclua recursos usando o Console de gerenciamento da AWS 1. Abra o console do Amazon MSK em [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Selecione o nome do seu cluster. Por exemplo, **MSKTutorialCluster**. 1. Escolha **Ações** e **Excluir**. 1. Abra o console do Amazon EC2 em [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. Escolha a instância que você criou para sua máquina cliente, por exemplo, **MSKTutorialClient**. 1. Escolha **Estado da instância** e **Encerrar instância**. **Para excluir a política e o perfil do IAM**Excluir o perfil e a política do IAM 1. Abra o console do IAM em [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/). 1. No painel de navegação, escolha **Perfis**. 1. Na caixa de pesquisa, insira o nome do perfil do IAM que você criou para este tutorial. 1. Selecione o perfil de . Escolha **Excluir perfil** e confirme a exclusão. 1. No painel de navegação, escolha **Políticas**. 1. Na caixa de pesquisa, insira o nome da política que você criou para este tutorial. 1. Escolha a política para abrir a respectiva página de resumo. Na página **Resumo** da política, escolha **Editar política**. 1. Escolha **Excluir**.