Langkah 5: Menghasilkan dan Mengkonsumsi Data

Untuk menghasilkan dan mengkonsumsi pesan

1. Jalankan perintah berikut untuk memulai produser konsol.

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

2. Masukkan pesan apa pun yang Anda inginkan, dan tekan Enter. Ulangi langkah ini dua atau tiga kali. Setiap kali Anda memasukkan baris dan tekan Enter, baris itu dikirim ke cluster Apache Kafka Anda sebagai pesan terpisah.

3. Biarkan koneksi ke mesin klien tetap terbuka, dan kemudian buka koneksi kedua yang terpisah ke mesin itu di jendela baru. Karena ini adalah sesi baru, atur variabel KAFKA_ROOT dan BOOTSTRAP_SERVER lingkungan lagi. Untuk informasi tentang cara mengatur variabel lingkungan ini, lihatMembuat topik di mesin klien.

4. Jalankan perintah berikut dengan string koneksi kedua Anda ke mesin klien untuk membuat konsumen konsol.

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

   Anda harus mulai melihat pesan yang Anda masukkan sebelumnya ketika Anda menggunakan perintah produser konsol.

5. Masukkan lebih banyak pesan di jendela produser, dan saksikan mereka muncul di jendela konsumen.