Paso 5: producción y consumo de datos

Producción y consumo de mensajes

1. Ejecute el siguiente comando para iniciar un productor de la consola. Sustituya BootstrapServerString por la cadena de conexión de texto simple que obtuvo en Crear un tema. Para obtener instrucciones sobre cómo recuperar esta cadena de conexión, consulte Getting the bootstrap brokers for an Amazon MSK cluster.

   <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list BootstrapServerString --producer.config client.properties --topic MSKTutorialTopic

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 Enter (Entrar), dicha línea se envía al clúster de Apache Kafka 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. En el siguiente comando, sustituya BootstrapServerString por la cadena de conexión de texto sin formato que guardó anteriormente. A continuación, para crear un consumidor de consola, ejecute el siguiente comando con la segunda conexión al equipo cliente.

   <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapServerString --consumer.config client.properties --topic MSKTutorialTopic --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.