Producción y consumo de datos en 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.

Producción y consumo de datos en MSK sin servidor

En este paso, se producirán y consumirán datos mediante el tema que creó en el paso anterior.

Producción y consumo de mensajes

  1. Ejecute el siguiente comando para crear un productor de la consola.

    <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list $BS --producer.config client.properties --topic msk-serverless-tutorial

  2. Escriba el mensaje que desee y pulse Enter (Entrar). Repita este paso dos o tres veces. Cada vez que introduzca una línea y pulse Entrar, dicha línea se enviará al clúster como un mensaje separado.

  3. Mantenga abierta la conexión al equipo cliente y, a continuación, abra una segunda conexión independiente a dicho equipo en una nueva ventana.

  4. Utilice la segunda conexión a la máquina cliente para crear un consumidor de consola con el siguiente comando. my-endpointSustitúyala por la cadena del servidor de arranque que guardaste después de crear el clúster.

    <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server my-endpoint --consumer.config client.properties --topic msk-serverless-tutorial --from-beginning

    Comenzará a ver los mensajes que introdujo anteriormente cuando utilizó el comando del productor de la consola.

  5. Escriba más mensajes en la ventana del productor y observe cómo aparecen en la ventana del consumidor.

Si tiene classpath problemas al ejecutar estos comandos, asegúrese de ejecutarlos desde el directorio correcto. Además, asegúrese de que el AWS MSK IAM JAR esté en el libs directorio. Como alternativa, puede ejecutar los comandos de Kafka utilizando el comando Java completo con explicitoclasspath, como se muestra en el siguiente ejemplo.

java -cp "kafka_2.12-2.8.1/libs/*:kafka_2.12-2.8.1/libs/aws-msk-iam-auth-2.3.0-all.jar" org.apache.kafka.tools.ConsoleProducer —broker-list $BS —producer.config client.properties —topic msk-serverless-tutorial

Paso siguiente

Eliminación de los recursos que creó para MSK sin servidor