Étape 5 : Produire et consommer des données

Pour produire et consommer des messages

1. Exécutez la commande suivante pour démarrer un producteur de console.

   $KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic

2. Saisissez le message souhaité, puis appuyez sur Entrée. Répétez cette étape deux ou trois fois. Chaque fois que vous entrez une ligne et appuyez sur Entrée, cette ligne est envoyée à votre cluster Apache Kafka sous forme de message distinct.

3. Gardez la connexion à l'ordinateur client ouverte, puis ouvrez une deuxième connexion séparée à cet ordinateur dans une nouvelle fenêtre. Comme il s'agit d'une nouvelle session, définissez à nouveau les variables d'BOOTSTRAP_SERVERenvironnement KAFKA_ROOT et. Pour plus d'informations sur la façon de définir ces variables d'environnement, consultezCréation d'un sujet sur la machine cliente.

4. Exécutez la commande suivante avec votre deuxième chaîne de connexion à la machine cliente pour créer un consommateur de console.

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

   Vous devriez commencer à voir les messages que vous avez entrés plus tôt lorsque vous avez utilisé la commande console producer.

5. Entrez d'autres messages dans la fenêtre du producteur et regardez-les apparaître dans la fenêtre du consommateur.