Passaggio 5: produzione e utilizzo di dati

Per produrre e consumare messaggi

1. Eseguire il comando seguente per avviare un produttore della console.

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

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

3. Mantenere aperta la connessione al computer client, quindi aprire una seconda connessione separata al computer in una nuova finestra. Poiché si tratta di una nuova sessione, impostate nuovamente le variabili di BOOTSTRAP_SERVER ambiente KAFKA_ROOT e di ambiente. Per informazioni su come impostare queste variabili di ambiente, vedereCreazione di un argomento sul computer client.

4. Esegui il comando seguente con la seconda stringa di connessione al computer client per creare un consumer della console.

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

   Dovresti iniziare a vedere i messaggi che hai inserito in precedenza quando hai usato il comando console producer.

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