Schritt 5: Produzieren und Verbrauchen von Daten

Erstellen und Verbrauchen von Nachrichten

1. Führen Sie den folgenden Befehl aus, um einen Konsolenproduzenten zu starten.

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

2. Geben Sie eine beliebige Nachricht ein, und drücken Sie Enter (Eingabetaste). Wiederholen Sie diesen Schritt zwei- oder dreimal. Jedes Mal, wenn Sie eine Zeile eingeben und Enter (Eingabetaste) drücken, wird diese Zeile als separate Nachricht an Ihren Apache Kafka-Cluster gesendet.

3. Lassen Sie die Verbindung zum Client-Computer geöffnet und öffnen Sie dann eine zweite separate Verbindung zu diesem Computer in einem neuen Fenster. Da es sich um eine neue Sitzung handelt, legen Sie die Umgebungsvariablen KAFKA_ROOT und die BOOTSTRAP_SERVER Umgebungsvariablen erneut fest. Hinweise zum Einstellen dieser Umgebungsvariablen finden Sie unterEin Thema auf dem Client-Computer erstellen.

4. Führen Sie den folgenden Befehl mit Ihrer zweiten Verbindungszeichenfolge zum Client-Computer aus, um einen Console-Consumer zu erstellen.

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

   Sie sollten nun die Meldungen sehen, die Sie zuvor eingegeben haben, als Sie den Befehl Console Producer verwendet haben.

5. Geben Sie weitere Nachrichten in das Producer-Fenster ein und beobachten Sie, wie sie im Consumer-Fenster angezeigt werden.