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. Como se trata de una sesión nueva, vuelva a configurar las variables KAFKA_ROOT y de BOOTSTRAP_SERVER entorno. Para obtener información sobre cómo configurar estas variables de entorno, consulteCrear un tema en la máquina cliente.

4. Ejecute el siguiente comando con la segunda cadena de conexión a 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 empezar a ver los mensajes que introdujo anteriormente cuando utilizó el comando console producer.

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