Paso 3: creación de una máquina cliente y un tema de Apache Kafka

En este paso, cree una instancia de Amazon EC2 para utilizarla como instancia de cliente de Apache Kafka. A continuación, utilice esta instancia para crear un tema en el clúster.

Creación de un equipo cliente

1. Abra la consola de Amazon EC2 en https://console.aws.amazon.com/ec2/.

2. Elija iniciar instancias.

3. Escriba un nombre para el equipo cliente, como mkc-tutorial-client.

4. Deje seleccionado Amazon Linux 2 AMI (HVM): Kernel 5.10, tipo de volumen SSD en Tipo de imagen de máquina de Amazon (AMI).

5. Elija el tipo de instancia t2.xlarge.

6. En Par de claves (inicio de sesión), seleccione Crear un nuevo par de claves. Introduzca mkc-tutorial-key-pair en Nombre del par de claves y, a continuación, seleccione Descargar par de claves. También puede utilizar un par de claves existente.

7. Seleccione Iniciar instancia.

8. 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.

Concesión de permiso al cliente recién creado para que envíe datos al clúster

1. Abra la consola de Amazon VPC en https://console.aws.amazon.com/vpc/.

2. En el panel izquierdo, en SEGURIDAD, elija Grupos de seguridad. En la columna ID de grupo de seguridad, busque el grupo de seguridad del clúster. Guardó el ID de este grupo de seguridad cuando creó el clúster en Paso 1: Configurar recursos necesarios. Seleccione este grupo de seguridad seleccionando la casilla situada a la izquierda de su fila. Asegúrese de que no haya otros grupos de seguridad seleccionados simultáneamente.

3. En la parte inferior de la pantalla, elija la pestaña Reglas de entrada.

4. Elija Editar reglas de entrada.

5. En la parte inferior izquierda de la pantalla, elija Añadir regla.

6. En la nueva regla, elija All traffic (Todo el tráfico) en la columna Type (Tipo). En el campo de la derecha de la columna Origen, escriba el ID del grupo de seguridad del equipo cliente. Este es el ID del grupo de seguridad que guardó después de crear el equipo cliente.

7. Seleccione Guardar reglas. Su clúster de MSK ahora aceptará todo el tráfico del cliente que creó en el procedimiento anterior.

Creación de un tema

1. Abra la consola de Amazon EC2 en https://console.aws.amazon.com/ec2/.

2. En la tabla de instancias, elija mkc-tutorial-client.

3. Cerca de la parte superior de la pantalla, seleccione Conectar y siga las instrucciones para conectarse a la instancia.

4. Instale Java en la instancia del cliente ejecutando el siguiente comando:

   sudo yum install java-1.8.0

5. Ejecute el siguiente comando para descargar Apache Kafka.

   wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz

   nota

   Si desea utilizar un sitio espejo que no sea el utilizado en este comando, puede elegir uno diferente en el sitio web de Apache.

6. Ejecute el siguiente comando en el directorio donde descargó el archivo TAR del paso anterior.

   tar -xzf kafka_2.12-2.2.1.tgz

7. Vaya al directorio kafka_2.12-2.2.1.

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

9. En el panel izquierdo, seleccione Clústeres y, a continuación, elija el nombre mkc-tutorial-cluster.

10. Seleccione Ver información del cliente.

11. Copie la cadena de conexión de texto sin formato.

12. Seleccione Listo.

13. Ejecute el siguiente comando en la instancia del cliente (mkc-tutorial-client) y bootstrapServerStringreemplácelo por el valor que guardó al ver la información del cliente del clúster.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server bootstrapServerString --replication-factor 2 --partitions 1 --topic mkc-tutorial-topic

    Si el comando se ejecuta correctamente, verá el siguiente mensaje: Created topic mkc-tutorial-topic.

Paso siguiente

Paso 4: creación del conector