Paso 4: creación de un tema

En este paso de Introducción a Amazon MSK, debe instalar las bibliotecas y herramientas del cliente de Apache Kafka en el equipo cliente y, a continuación, creer un tema.

aviso

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 a una versión del cliente anterior le falten determinadas características y correcciones de errores críticos.

Búsqueda de la versión del clúster de MSK

1. Vaya a https://eu-west-2.console.aws.amazon.com/msk/

2. Seleccione el clúster de MSK.

3. Anote la versión de Apache Kafka utilizada en el clúster.

4. 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 el equipo cliente

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

2. En el panel de navegación, seleccione Instancias. A continuación, seleccione la casilla de verificación situada junto al nombre del equipo cliente que creó en Paso 3: creación de un equipo cliente.

3. Elija Actions (Acciones) y, a continuación, elija Connect (Conectar). Siga las instrucciones de la consola para conectarse al equipo cliente.

4. Instale Java en el equipo cliente ejecutando el siguiente comando:

   sudo yum -y install java-11

5. Ejecute el siguiente comando para descargar Apache Kafka.

   wget https://archive.apache.org/dist/kafka/{YOUR MSK VERSION}/kafka_2.13-{YOUR MSK VERSION}.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.13-{YOUR MSK VERSION}.tgz

7. Vaya al directorio kafka_2.13-{YOUR MSK VERSION}/libs y ejecute el siguiente comando para descargar el archivo JAR de IAM de Amazon MSK. El JAR de IAM de Amazon MSK permite que el equipo cliente acceda al clúster.

   wget https://github.com/aws/aws-msk-iam-auth/releases/download/v1.1.1/aws-msk-iam-auth-1.1.1-all.jar

8. Vaya al directorio kafka_2.13-{YOUR MSK VERSION}/bin. Copie las siguientes configuraciones de propiedades y péguelas en un archivo nuevo. Asigne el nombre client.properties al archivo y guárdelo.

   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

9. Abra la consola de Amazon MSK en https://console.aws.amazon.com/msk/.

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

11. Seleccione Ver información del cliente.

12. Copie la cadena de conexión del punto de conexión privado.

    Obtendrá tres puntos de conexión para cada uno de los agentes. Solo necesita un punto de conexión de agente para el siguiente paso.

13. Ejecute el siguiente comando y BootstrapServerStringsustitúyalo por uno de los puntos finales del broker que obtuvo en el paso anterior.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server BootstrapServerString --command-config client.properties --replication-factor 3 --partitions 1 --topic MSKTutorialTopic

    Si el comando se ejecuta correctamente, verá el siguiente mensaje: Created topic MSKTutorialTopic.

Paso siguiente

Paso 5: producción y consumo de datos