Fase 5: Produrre e consumare dati

In questa fase, verranno prodotti e si consumo di dati utilizzando l'argomento creato nella fase precedente.

Per produrre e consumare messaggi

1. Per creare un produttore di console, eseguire il comando seguente.

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

2. Immettere qualsiasi messaggio desiderato e premere Enter (Invio). Ripetere questa fase due o tre volte. Ogni volta che si entra in una riga e si premeInvio, tale riga viene inviata al cluster come un messaggio separato.

3. Mantenere aperta la connessione al computer client, quindi aprire una seconda connessione separata al computer in una nuova finestra.

4. Utilizzare la seconda connessione al computer client per creare un consumer console con il comando seguente. Replace (Sostituisci)my-endpointcon la stringa del server di bootstrap che hai salvato dopo aver creato il cluster.

   <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server my-endpoint --consumer.config client.properties --topic msk-serverless-tutorial --from-beginning

   Si iniziano a vedere i messaggi immessi in precedenza quando è stato utilizzato il comando produttore della console.

5. Immettere altri messaggi nella finestra del produttore e guardali apparire nella finestra del consumatore.

Fase successiva

Fase 6: Delete resources (Elimina risorse)