Cree una máquina cliente para acceder al clúster MSK sin servidor - Transmisión gestionada de Amazon para Apache Kafka

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.

Cree una máquina cliente para acceder al clúster MSK sin servidor

En este paso, se realizan dos tareas. La primera tarea consiste en crear una EC2 instancia de Amazon para utilizarla como máquina cliente de Apache Kafka. La segunda tarea consiste en instalar las herramientas de Java y Apache Kafka en el equipo.

Creación de un equipo cliente

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

  2. Seleccione Iniciar instancia.

  3. Escriba un Nombre descriptivo para el equipo cliente, como msk-serverless-tutorial-client.

  4. Deje la opción Amazon Linux 2 AMI (HVM) - Kernel 5.10, tipo de SSD volumen seleccionada para el tipo Amazon Machine Image (AMI).

  5. Deje seleccionado el tipo de instancia t2.micro.

  6. En Par de claves (inicio de sesión), seleccione Crear un nuevo par de claves. Introduzca MSKServerlessKeyPair en Nombre de par de claves. Luego, elija Descargar par de claves. También puede utilizar un par de claves existente.

  7. En Configuración de red, elija Editar.

  8. En la sección VPC, introduzca el ID de la nube privada virtual (VPC) del clúster sin servidor. Se VPC basa en el VPC servicio de Amazon cuyo ID guardaste después de crear el clúster.

  9. En Subred, elija la subred cuyo ID guardó después de crear el clúster.

  10. En Firewall (grupos de seguridad), seleccione el grupo de seguridad asociado al clúster. Este valor funciona si ese grupo de seguridad tiene una regla de entrada que permite el tráfico desde el grupo de seguridad hacia sí mismo. Con esta regla, los miembros del mismo grupo de seguridad se pueden comunicar entre sí. Para obtener más información, consulte las reglas de los grupos de seguridad en la Guía para VPC desarrolladores de Amazon.

  11. Amplíe la sección de detalles avanzados y elija el IAM rol en el que lo creóCree un IAM rol para los temas MSK del clúster sin servidor.

  12. Elija Iniciar.

  13. En el panel de navegación izquierdo, elija instancias. A continuación, selecciona la casilla de verificación de la fila que representa la EC2 instancia de Amazon recién creada. A partir de ahora, esta instancia se denominará equipo cliente.

  14. Elija Conectar y siga las instrucciones para conectarse al equipo cliente.

Configuración de las herramientas de cliente de Apache Kafka en el equipo cliente

  1. Para instalar Java, ejecute el siguiente comando en el equipo cliente:

    sudo yum -y install java-11

  2. Para obtener las herramientas de Apache Kafka que se necesitan para crear temas y enviar datos, ejecute los siguientes comandos:

    wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
    tar -xzf kafka_2.12-2.8.1.tgz

  3. Ve al kafka_2.12-2.8.1/libs directorio y ejecuta el siguiente comando para descargar el MSK IAM JAR archivo de Amazon. Amazon MSK IAM JAR hace posible que la máquina 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

  4. Vaya al directorio kafka_2.12-2.8.1/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

Paso siguiente

Cree un tema sobre Apache Kafka