Producción y consumo de datos en MSK sin servidor

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. Sustituya my-endpoint por la cadena de servidor de arranque que guardó 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.