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. # Introducción a Amazon MSK En este tutorial, se muestra un ejemplo de cómo crear un clúster de MSK, cómo producir y consumir datos y cómo supervisar el estado del clúster mediante métricas. Este ejemplo no representa todas las opciones que puede elegir al crear un clúster de MSK. En diferentes partes de este tutorial, elegimos opciones predeterminadas por motivos de simplicidad. Esto no significa que sean las únicas opciones que funcionan para configurar un clúster de MSK o instancias de cliente. **Topics** + [Paso 1: Creación de un clúster de MSK aprovisionado](create-cluster.md) + [Paso 2: creación de un rol de IAM que otorgue acceso a la creación de temas en el clúster de Amazon MSK](create-client-iam-role.md) + [Paso 3: creación de un equipo cliente](create-client-machine.md) + [Paso 4: creación de un tema en el clúster de Amazon MSK](create-topic.md) + [Paso 5: producción y consumo de datos](produce-consume.md) + [Paso 6: Usa Amazon CloudWatch para ver las métricas de Amazon MSK](view-metrics.md) + [Paso 7: Elimine los AWS recursos creados para este tutorial](delete-cluster.md) # Paso 1: Creación de un clúster de MSK aprovisionado En este paso de [Introducción al uso de Amazon MSK](getting-started.md), crea un clúster de Amazon MSK aprovisionado. **Para crear este clúster, utilice la opción Consola de administración de AWS de creación rápida**. **Para crear un clúster de Amazon MSK mediante Consola de administración de AWS**Cree un clúster mediante el Consola de administración de AWS 1. ¿Iniciar sesión en la Consola de administración de AWS consola Amazon MSK y abrirla desde [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. Elija **Create cluster**. 1. En **Método de creación**, deje seleccionada la opción **Creación rápida**. La opción **Creación rápida** le permite crear un clúster con la configuración predeterminada. 1. En **Nombre del clúster**, ingrese un nombre para el clúster. Por ejemplo, **MSKTutorialCluster**. 1. En **Propiedades generales del clúster**, realice lo siguiente: 1. En **Tipo de clúster**, seleccione **Aprovisionado**. 1. Seleccione una **versión de Apache Kafka** que se ejecutará en los agentes. Seleccione **Ver compatibilidad de versiones** para consultar la tabla comparativa. 1. En **Tipo de agente**, elija Standard o Express. 1. Seleccione un **Tamaño de agente**. 1. En la tabla que aparece debajo de **Todas las configuración del clúster**, copie los valores de las siguientes configuraciones y guárdalos, ya que los necesitará más adelante en este tutorial: + VPC + Subredes + Grupos de seguridad asociados con la VPC 1. Elija **Create cluster**. 1. Compruebe el estado del clúster en **Estado**, en la página **Resumen del clúster**. El estado cambia de **En creación** a **Activo** a medida que Amazon MSK aprovisiona el clúster. Cuando el estado sea **Activo**, puede conectarse al clúster. Para obtener más información acerca del estado de un clúster, consulte [Descripción de los estados de los clústeres de MSK aprovisionados](msk-cluster-states.md). **Paso siguiente** [Paso 2: creación de un rol de IAM que otorgue acceso a la creación de temas en el clúster de Amazon MSK](create-client-iam-role.md) # Paso 2: creación de un rol de IAM que otorgue acceso a la creación de temas en el clúster de Amazon MSK En este paso, se realizan dos tareas. La primera tarea consiste en crear una política de IAM que conceda acceso para crear temas en el clúster y enviarles datos. La segunda tarea consiste en crear un rol de IAM y asociarle esta política. En un paso posterior, se crea un equipo cliente que asume este rol y lo utiliza para crear un tema en el clúster y enviar datos a ese tema. **Creación de una política de IAM que permita crear temas y escribir en ellos**Creación de una política de IAM 1. Abra la consola de IAM en [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/). 1. En el panel de navegación, seleccione **Políticas**. 1. Elija **Crear política**. 1. En **Editor de políticas**, elija **JSON** y, a continuación, reemplace el JSON en la ventana del editor por el siguiente JSON. En el ejemplo siguiente, sustituya: + *region*con el código del lugar donde creaste tu clúster. Región de AWS + Ejemplo de ID de cuenta*123456789012*, con tu Cuenta de AWS ID. + *MSKTutorialCluster*y*MSKTutorialCluster*/*7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14*, con el nombre del clúster y su 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 obtener instrucciones sobre cómo escribir políticas seguras, consulte [Control de acceso de IAM](iam-access-control.md). 1. Elija **Siguiente**. 1. En la página **Revisar y crear**, haga lo siguiente: 1. En **Nombre de la política**, introduzca un nombre descriptivo, como **msk-tutorial-policy**. 1. En **Permisos definidos en esta política**, revisa y and/or edita los permisos definidos en tu política. 1. (Opcional) Para ayudar a identificar, organizar o buscar la política, elija **Agregar nueva etiqueta** para agregar etiquetas como pares clave-valor. Por ejemplo, agregue una etiqueta a la política con el par clave-valor de **Environment** y **Test**. Para obtener más información sobre el uso de etiquetas, consulte [Etiquetas para AWS Identity and Access Management recursos](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) en la *Guía del usuario de IAM*. 1. Elija **Crear política**. **Creación de un rol de IAM y asociarle la política** 1. En el panel de navegación, seleccione **Roles** y luego seleccione **Crear rol**. 1. En la página **Seleccionar entidad de confianza**, haga lo siguiente: 1. En **Tipo de entidad de confianza**, elija **Servicio de AWS**. 1. En **Servicio o caso de uso**, elija **EC2**. 1. En **Caso de uso**, elija **EC2**. 1. Elija **Siguiente**. 1. En la página **Agregar permisos**, haga lo siguiente: 1. En el cuadro de búsqueda de **Políticas de permisos**, introduzca el nombre de la política que creó previamente para este tutorial. A continuación, marque la casilla situada a la izquierda del nombre de la política. 1. (Opcional) Configure un [límite de permisos](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_boundaries.html). Se trata de una característica avanzada que está disponible para los roles de servicio, pero no para los roles vinculados a servicios. Para obtener información sobre cómo establecer un límite de permisos, consulte [Creación de roles y asociación de políticas (consola)](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_job-functions_create-policies.html) en la *Guía del usuario de IAM*. 1. Elija **Siguiente**. 1. En la página **Nombrar, revisar y crear**, haga lo siguiente: 1. En **Nombre del rol**, introduzca un nombre descriptivo, como **msk-tutorial-role**. **importante** Cuando asigne un nombre a un rol, tenga en cuenta lo siguiente: Los nombres de los roles deben ser únicos dentro de tu Cuenta de AWS perfil y no se pueden hacer únicos por mayúsculas y minúsculas. Por ejemplo, no puedes crear roles denominados tanto **PRODROLE** como **prodrole**. Cuando se utiliza un nombre de rol en una política o como parte de un ARN, el nombre de rol distingue entre mayúsculas y minúsculas, sin embargo, cuando un nombre de rol les aparece a los clientes en la consola, como por ejemplo durante el proceso de inicio de sesión, el nombre de rol no distingue entre mayúsculas y minúsculas. Dado que otras entidades podrían hacer referencia al rol, no es posible editar el nombre del rol una vez creado. 1. (Opcional) **En Descripción**, ingrese una descripción para el rol. 1. (Opcional) Para editar los casos de uso y los permisos del rol, en las secciones **Paso 1: Seleccionar entidades de confianza** o **Paso 2: Agregar permisos**, elija **Editar**. 1. (Opcional) Para ayudar a identificar, organizar o buscar el rol, elija **Agregar nueva etiqueta** para agregar etiquetas como pares clave-valor. Por ejemplo, agregue una etiqueta al rol con el par clave-valor de **ProductManager** y **John**. Para obtener más información sobre el uso de etiquetas, consulte [Etiquetas para obtener AWS Identity and Access Management recursos](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) en la *Guía del usuario de IAM*. 1. Revise el rol y, a continuación, elija **Crear rol**. **Paso siguiente** [Paso 3: creación de un equipo cliente](create-client-machine.md) # Paso 3: creación de un equipo cliente En este paso de [Introducción a Amazon MSK](getting-started.md), creará un equipo cliente. Utilice este equipo cliente para crear un tema que produzca y consuma datos. Para simplificar, creará este equipo cliente en la VPC asociada al clúster de MSK para que el cliente pueda conectarse fácilmente al clúster. **Creación de un equipo cliente**Creación de un equipo cliente 1. Abra la consola de Amazon EC2 en [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. En el panel de la consola de Amazon EC2, elija **Iniciar instancia**. 1. En **Nombre y etiquetas**, en **Nombre**, introduzca un nombre descriptivo para la máquina cliente, de modo que pueda identificarla y realizar un seguimiento de esta con facilidad. Por ejemplo, **MSKTutorialClient**. 1. En **Aplicación e imágenes del sistema operativo (imagen de máquina de Amazon)**, en **Imagen de máquina de Amazon (AMI)**, seleccione **AMI de Amazon Linux 2 (HVM) – Kernel 5.10, tipo de volumen SSD**. 1. En **Tipo de instancia**, mantenga la selección predeterminada **t2.micro**. 1. En **Par de claves (inicio de sesión)**, seleccione un par de claves existente o cree uno nuevo. Si no necesita un par de claves para conectarse a la instancia, puede seleccionar **Continuar sin un par de claves (no recomendado)**. Para crear un nuevo par de claves, haga lo siguiente: 1. Seleccione **Crear un nuevo par de claves**. 1. En **Key pair name** (Nombre del par de claves), ingrese **MSKKeyPair**. 1. En **Tipo de par de claves** y **Formato del archivo de clave privada**, mantenga las selecciones predeterminadas. 1. Elija **Crear par de claves**. También puede utilizar un par de claves existente. 1. Desplácese hacia abajo en la página y expanda la sección **Detalles avanzados**. A continuación, realice lo siguiente: 1. En **Perfil de instancia de IAM**, seleccione un rol de IAM que desee que la máquina cliente asuma. Si no dispone de un rol de IAM, realice lo siguiente: 1. Seleccione **Crear un nuevo perfil de IAM**. 1. Complete los pasos descritos en el [Paso 2: Creación de un rol de IAM](create-client-iam-role.md). 1. Seleccione **Iniciar instancia**. 1. Elija **View Instances (Ver instancias)**. A continuación, en la columna **Grupos de seguridad**, elija el grupo de seguridad asociado a la nueva instancia. Copie el ID del grupo de seguridad y guárdelo para más adelante. 1. Abra la consola de Amazon VPC en [https://console.aws.amazon.com/vpc/](https://console.aws.amazon.com/vpc/). 1. En el panel de navegación, elija **Grupos de seguridad**. Busque el grupo de seguridad cuyo ID guardó en [Paso 1: Creación de un clúster de MSK aprovisionado](create-cluster.md). 1. En la pestaña **Reglas de entrada**, elija **Editar reglas de entrada**. 1. Seleccione **Agregar regla**. 1. En la nueva regla, elija **All traffic (Todo el tráfico)** en la columna **Type (Tipo)**. En el segundo campo de la columna **Origen** escriba el ID del grupo de seguridad del equipo cliente. Este es el grupo cuyo nombre guardó después de lanzar la instancia de la máquina cliente. 1. Seleccione **Guardar reglas**. Ahora, el grupo de seguridad del clúster puede aceptar el tráfico que proviene del grupo de seguridad de la máquina cliente. **Paso siguiente** [Paso 4: creación de un tema en el clúster de Amazon MSK](create-topic.md) # Paso 4: creación de un tema en el clúster de Amazon MSK En este paso de [Introducción a Amazon MSK](getting-started.md), puede crear un tema con uno de estos dos enfoques: usar AWS herramientas nativas con la CreateTopic API o usar AdminClient herramientas de Apache Kafka en un equipo cliente. **aviso** Cuando utilice AWS herramientas con la CreateTopic API, compruebe que el clúster cumpla los requisitos. Para obtener más información, consulte [el tema Requisitos de uso APIs](https://docs.aws.amazon.com/msk/latest/developerguide/msk-topic-operations-information.html#topic-operations-requirements). **aviso** Al utilizar este AdminClient enfoque, los números de versión de Apache Kafka utilizados en este tutorial son solo ejemplos. Se recomienda utilizar la misma versión del cliente que la versión de clúster de MSK. Es posible que una versión anterior del cliente carezca de determinadas características y correcciones críticas de errores. **Topics** + [Crear un tema mediante herramientas AWS](#create-topic-aws-tools) + [Determinación de la versión del clúster de MSK](#find-msk-cluster-version) + [Creación de un tema en la máquina cliente](#create-topic-client-machine) ## Crear un tema mediante herramientas AWS Puede crear temas en su clúster de MSK mediante AWS herramientas como la AWS CLI o la consola AWS de administración. AWS SDKs Este enfoque proporciona una forma simplificada de gestionar los temas sin necesidad de acceso directo a las herramientas de cliente de Kafka. Para obtener información detallada sobre la creación de temas con las AWS herramientas, consulte la guía para [desarrolladores de CreateTopic API](https://docs.aws.amazon.com/msk/latest/developerguide/msk-create-topic.html). ## Determinación de la versión del clúster de MSK 1. Abra la consola de Amazon MSK en [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. En la barra de navegación, seleccione la región en la que creó el clúster de MSK. 1. Seleccione el clúster de MSK. 1. Anote la versión de Apache Kafka utilizada en el clúster. 1. Sustituya las instancias de los números de versión de Amazon MSK de este tutorial por la versión obtenida en el paso 3. ## Creación de un tema en la máquina cliente 1. **Conéctese a la máquina cliente.** 1. Abra la consola de Amazon EC2 en [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. En el panel de navegación, seleccione **Instances (Instancias)**. A continuación, seleccione la casilla de verificación situada junto al nombre de la máquina cliente que creó en [Paso 3: creación de un equipo cliente](create-client-machine.md). 1. Elija **Actions (Acciones)** y, a continuación, elija **Connect (Conectar)**. Siga las instrucciones de la consola para conectarse al equipo cliente. 1. **Instale Java y configure la variable de entorno de la versión de Kafka.** 1. Instale Java en la máquina cliente mediante la ejecución del siguiente comando. ``` sudo yum -y install java-11 ``` 1. Guarde la [versión de Kafka](#find-msk-cluster-version) del clúster de MSK en la variable de entorno, `KAFKA_VERSION`, tal como se muestra en el siguiente comando. Necesitará esta información durante todo el proceso de configuración. ``` export KAFKA_VERSION={KAFKA VERSION} ``` Por ejemplo, si utiliza la versión 3.6.0, use el siguiente comando. ``` export KAFKA_VERSION=3.6.0 ``` 1. **Descargue y extraiga Apache Kafka.** 1. Ejecute el siguiente comando para descargar Apache Kafka. ``` wget https://archive.apache.org/dist/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz ``` **nota** La siguiente lista presenta algunas alternativas para la descarga de Kafka que puede utilizar si experimenta algún problema. Si experimenta problemas de conectividad o desea utilizar un sitio espejo, pruebe con el selector de espejos de Apache, tal como se muestra en el siguiente comando. ``` wget https://www.apache.org/dyn/closer.cgi?path=/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz ``` Descargue una versión adecuada directamente desde el [sitio web de Apache Kafka](https://kafka.apache.org/downloads). 1. Ejecute el siguiente comando en el directorio donde descargó el archivo TAR del paso anterior. ``` tar -xzf kafka_2.13-$KAFKA_VERSION.tgz ``` 1. Guarde la ruta completa del directorio recién creado en la variable de entorno `KAFKA_ROOT`. ``` export KAFKA_ROOT=$(pwd)/kafka_2.13-$KAFKA_VERSION ``` 1. **Configure la autenticación para el clúster de MSK.** 1. [Busque la versión más reciente](https://github.com/aws/aws-msk-iam-auth/releases/latest) de la biblioteca cliente de IAM para Amazon MSK. Esta biblioteca permite que la máquina cliente acceda al clúster de MSK mediante autenticación con IAM. 1. Mediante los siguientes comandos, navegue hasta el directorio `$KAFKA_ROOT/libs` y descargue el archivo JAR de IAM para Amazon MSK correspondiente que identificó en el paso anterior. Asegúrate de *\$1LATEST VERSION\$1* reemplazarlo por el número de versión real que estás descargando. ``` 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 ejecutar cualquier comando de Kafka que interactúe con el clúster de Amazon MSK, es posible que deba agregar el archivo JAR de IAM de Amazon MSK a la ruta de clases de Java. Establezca la variable de entorno `CLASSPATH`, tal como se muestra en el siguiente ejemplo. ``` export CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar ``` Esto configura `CLASSPATH` para toda la sesión, lo que hace que el archivo JAR esté disponible para todos los comandos de Kafka posteriores. 1. Vaya al directorio `$KAFKA_ROOT/config` para crear el archivo de configuración del cliente. ``` cd $KAFKA_ROOT/config ``` 1. Copie las siguientes configuraciones de propiedades y péguelas en un archivo nuevo. Guarde el archivo 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 el tamaño del montón de Java para las herramientas de Kafka. ** Si experimenta problemas relacionados con la memoria o trabaja con una gran cantidad de temas o particiones, puede ajustar el tamaño del montón de Java. Para ello, configure la variable de entorno `KAFKA_HEAP_OPTS` antes de ejecutar los comandos de Kafka. El siguiente ejemplo establece tanto el tamaño máximo como el tamaño inicial del montón en 512 megabytes. Ajuste estos valores según sus requisitos específicos y los recursos del sistema disponibles. ``` export KAFKA_HEAP_OPTS="-Xmx512M -Xms512M" ``` 1. **Obtenga la información de conexión del clúster.** 1. Abra la consola de Amazon MSK en [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Espere a que el estado del clúster pase a ser **Activo**. Esto podría tardar varios minutos. Cuando el estado pase a ser **Activo**, elija el nombre del clúster. Se le redirigirá a una página que contiene el resumen del clúster. 1. Seleccione **Ver información del cliente**. 1. Copie la cadena de conexión del punto de conexión privado. Obtendrá tres puntos de conexión para cada uno de los agentes. Almacene una de estas cadenas de conexión en la variable de entorno `BOOTSTRAP_SERVER`, como se muestra en el siguiente comando. **Sustitúyalo por el valor real de la cadena de conexión. ``` export BOOTSTRAP_SERVER= ``` 1. **Ejecute el siguiente comando para crear el tema.** ``` $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 ``` Si recibe un error `NoSuchFileException` para el archivo `client.properties`, asegúrese de que este archivo exista en el directorio de trabajo actual, dentro del directorio bin de Kafka. **nota** Si prefiere no establecer la variable de entorno `CLASSPATH` para toda la sesión, puede, como alternativa, anteponer cada comando de Kafka con la variable `CLASSPATH`. Este enfoque aplica la ruta de clases únicamente a ese 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 que el tema se haya creado correctamente.** 1. Si el comando se ejecuta correctamente, debería ver el siguiente mensaje: `Created topic MSKTutorialTopic.` 1. Enumere todos los temas para confirmar que el tema existe. ``` $KAFKA_ROOT/bin/kafka-topics.sh --list --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties ``` Si el comando no se ejecuta correctamente o experimenta un error, consulte [Solución de problemas del clúster de Amazon MSK](troubleshooting.md) para obtener información de solución de problemas. 1. **(Opcional) Elimine las variables de entorno que utilizó en este tutorial.** Si desea conservar las variables de entorno para los siguientes pasos de este tutorial, omita este paso. De lo contrario, puede desestablecer estas variables, como se muestra en el siguiente ejemplo. ``` unset KAFKA_VERSION KAFKA_ROOT BOOTSTRAP_SERVER CLASSPATH KAFKA_HEAP_OPTS ``` **Paso siguiente** [Paso 5: producción y consumo de datos](produce-consume.md) # Paso 5: producción y consumo de datos En este paso de [Introducción a Amazon MSK](getting-started.md), producirá y consumirá datos. **Producción y consumo de mensajes**Producción y consumo de mensajes 1. Ejecute el siguiente comando para iniciar un productor de la consola. ``` $KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic ``` 1. Escriba el mensaje que desee y pulse **Enter (Entrar)**. Repita este paso dos o tres veces. Cada vez que introduzca una línea y pulse **Enter (Entrar)**, dicha línea se envía al clúster de Apache Kafka como un mensaje separado. 1. Mantenga abierta la conexión al equipo cliente y, a continuación, abra una segunda conexión independiente a dicho equipo en una nueva ventana. Debido a que se trata de una nueva sesión, establezca nuevamente las variables de entorno `KAFKA_ROOT` y `BOOTSTRAP_SERVER`. Para obtener información sobre cómo establecer estas variables de entorno, consulte [Creación de un tema en la máquina cliente](create-topic.md#create-topic-client-machine). 1. Ejecute el siguiente comando con la segunda cadena de conexión en la máquina cliente para crear un consumidor de consola. ``` $KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning ``` Debería comenzar a ver los mensajes que introdujo anteriormente cuando utilizó el comando del productor de consola. 1. Escriba más mensajes en la ventana del productor y observe cómo aparecen en la ventana del consumidor. **Paso siguiente** [Paso 6: Usa Amazon CloudWatch para ver las métricas de Amazon MSK](view-metrics.md) # Paso 6: Usa Amazon CloudWatch para ver las métricas de Amazon MSK En este paso de [Introducción a Amazon MSK](getting-started.md), analizará las métricas de Amazon MSK en Amazon. CloudWatch **Para ver las métricas de Amazon MSK en CloudWatch**Vea las métricas en CloudWatch 1. Abre la CloudWatch consola en [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/). 1. En el panel de navegación, seleccione **Métricas**. 1. Seleccione la pestaña **All metrics (Todas las métricas)** y, a continuación, seleccione **AWS/Kafka**. 1. Para ver métricas de nivel de agente, elija **Broker ID, Cluster Name (ID de agente, Nombre del clúster)**. En las métricas de nivel de clúster, elija **Cluster Name (Nombre del clúster)**. 1. (Opcional) En el panel de gráficos, seleccione una estadística y un período de tiempo y, a continuación, cree una CloudWatch alarma con estos ajustes. **Paso siguiente** [Paso 7: Elimine los AWS recursos creados para este tutorial](delete-cluster.md) # Paso 7: Elimine los AWS recursos creados para este tutorial En el último paso de [Introducción a Amazon MSK](getting-started.md), debe eliminar el clúster de MSK y el equipo cliente que creó para este tutorial. **Para eliminar los recursos mediante el Consola de administración de AWS**Elimine los recursos mediante el Consola de administración de AWS 1. Abra la consola de Amazon MSK en [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Elija el nombre del clúster. Por ejemplo, **MSKTutorialClúster**. 1. Seleccione **Actions (Acciones)** y, a continuación, seleccione **Delete (Eliminar)**. 1. Abra la consola de Amazon EC2 en [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. Elija la instancia que creó para el equipo cliente, por ejemplo, **MSKTutorialClient**. 1. Elija **Estado de la instancia** y, luego, **Terminar instancia**. **Eliminación de la política y el rol de IAM**Eliminación de la política y el rol de IAM 1. Abra la consola de IAM en [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/). 1. En el panel de navegación, seleccione **Roles**. 1. En el cuadro de búsqueda, escriba el nombre del rol de IAM que creó para este tutorial. 1. Elija el rol. A continuación, elija **Eliminar rol** para confirmar la eliminación. 1. En el panel de navegación, seleccione **Políticas**. 1. En el cuadro de búsqueda, escriba el nombre de la política que creó para este tutorial. 1. Elija la política para abrir su página de resumen. En la página **Resumen** de la política, elija **Eliminar política**. 1. Elija **Eliminar**.