Produzieren und konsumieren Sie Daten in Serverless MSK

Erstellen und Verbrauchen von Nachrichten

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

   <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list $BS --producer.config client.properties --topic msk-serverless-tutorial

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 Eingabe 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. Verwenden Sie Ihre zweite Verbindung zum Client-Computer, um mit dem folgenden Befehl einen Konsolen-Verbraucher zu erstellen. Ersetzen my-endpoint mit der Bootstrap-Serverzeichenfolge, die Sie nach der Erstellung des Clusters gespeichert haben.

   <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server my-endpoint --consumer.config client.properties --topic msk-serverless-tutorial --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.