Creación de un tema de Apache Kafka - Transmisión gestionada de Amazon para Apache Kafka
Configuración del entorno para la creación de temasCrear un tema y escribir datos en él

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.

Creación de un tema de Apache Kafka

En este paso, utilizará el equipo cliente creado anteriormente para crear un tema en el clúster sin servidor.

Configuración del entorno para la creación de temas

  • Antes de crear un tema, asegúrese de haber descargado el archivo JAR de IAM de AWS MSK en el directorio de la instalación de Kafka. libs/ Si aún no lo ha hecho, ejecute el siguiente comando en el directorio de Kafka. libs/

    wget https://github.com/aws/aws-msk-iam-auth/releases/download/v2.3.0/aws-msk-iam-auth-2.3.0-all.jar

    Este archivo JAR es necesario para la autenticación de IAM con su clúster MSK Serverless.

  • Al ejecutar los comandos de Kafka, es posible que tengas que asegurarte de que classpath incluyen el archivo JAR de IAM de AWS MSK. Para ello, siga uno de estos pasos:

    • Configure la variable de CLASSPATH entorno para incluir las bibliotecas de Kafka, como se muestra en el siguiente ejemplo.

      export CLASSPATH=<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar

    • Ejecute los comandos de Kafka utilizando el comando Java completo con explicitoclasspath, como se muestra en el siguiente ejemplo.

      java -cp "<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar" org.apache.kafka.tools.TopicCommand --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6

Crear un tema y escribir datos en él

  1. En el siguiente export comando, my-endpoint sustitúyala por la cadena bootstrap-server que guardaste después de crear el clúster. A continuación, vaya al directorio kafka_2.12-2.8.1/bin del equipo cliente y ejecute el comando export.

    export BS=my-endpoint

  2. Ejecute el siguiente comando para crear un tema denominado msk-serverless-tutorial.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6

Paso siguiente

Producción y consumo de datos en MSK sin servidor