Creación de un tema de Apache Kafka - Transmisión administrada de Amazon para Apache Kafka
Configuración del entorno para crear temasCreación de un tema y escritura de datos en este

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 crear temas

  • Antes de crear un tema, asegúrate de haber descargado el archivo JAR de AWS MSK IAM en el directorio de tu instalación de Kafka. libs/ Si aún no ha realizado este paso, ejecute el siguiente comando en el directorio libs/ de Kafka.

    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 el clúster de MSK sin servidor.

  • 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 entorno CLASSPATH 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 mediante el comando completo de Java con classpath explícito, 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

Creación de un tema y escritura de datos en este

  1. En el siguiente export comando, my-endpoint sustitúyalo por la cadena bootstrap-server que guardó 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