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.

   $KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/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. Debido a que se trata de una nueva sesión, establezca nuevamente las variables de entorno KAFKA_ROOT y BOOTSTRAP_SERVER. Para obtener información sobre cómo establecer estas variables de entorno, consulte Creación de un tema en la máquina cliente.

4. Ejecute el siguiente comando con la segunda cadena de conexión en la máquina cliente para crear un consumidor de consola.

   $KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning

   Debería comenzar a ver los mensajes que introdujo anteriormente cuando utilizó el comando del productor de consola.

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