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. BootstrapServerStringErsetzen Sie es durch die Klartext-Verbindungszeichenfolge, die Sie unter Thema erstellen erhalten haben. Anweisungen zum Abrufen dieser Verbindungszeichenfolge finden Sie unter Bootstrap-Broker für einen Amazon-MSK-Cluster abrufen.

   <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list BootstrapServerString --producer.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.

4. Ersetzen Sie im folgenden Befehl BootstrapServerString durch die Klartext-Verbindungszeichenfolge, die Sie zuvor gespeichert haben. Verwenden Sie dann Ihre zweite Verbindung zum Client-Computer, um mit dem folgenden Befehl einen Konsolen-Verbraucher zu erstellen.

   <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapServerString --consumer.config client.properties --topic MSKTutorialTopic --from-beginning

   Sie sehen die Nachrichten, die Sie zuvor eingegeben haben, als Sie den Konsolenproduzentenbefehl verwendet haben.

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