Langkah 5: Menghasilkan dan mengkonsumsi data

Untuk menghasilkan dan mengkonsumsi pesan

1. Jalankan perintah berikut untuk memulai produsen 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 menekan Enter, baris itu dikirim ke cluster Apache Kafka Anda sebagai pesan terpisah.

3. Biarkan koneksi ke mesin klien tetap terbuka, lalu 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 produsen konsol.

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