View a markdown version of this page

Menghasilkan dan mengkonsumsi data di MSK Serverless - Amazon Managed Streaming untuk Apache Kafka

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Menghasilkan dan mengkonsumsi data di MSK Serverless

Pada langkah ini, Anda menghasilkan dan mengkonsumsi data menggunakan topik yang Anda buat pada langkah sebelumnya.

Untuk menghasilkan dan mengkonsumsi pesan

  1. Jalankan perintah berikut untuk membuat produsen konsol.

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

  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 Anda sebagai pesan terpisah.

  3. Biarkan koneksi ke mesin klien tetap terbuka, lalu buka koneksi kedua yang terpisah ke mesin itu di jendela baru.

  4. Gunakan koneksi kedua Anda ke mesin klien untuk membuat konsumen konsol dengan perintah berikut. Ganti my-endpoint dengan string server bootstrap yang Anda simpan setelah Anda membuat 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

    Anda 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.

Jika Anda mengalami classpath masalah saat menjalankan perintah ini, pastikan Anda menjalankannya dari direktori yang benar. Juga, pastikan bahwa JAR AWS MSK IAM ada di direktorilibs. Atau, Anda dapat menjalankan perintah Kafka menggunakan perintah Java lengkap dengan eksplisitclasspath, seperti yang ditunjukkan pada contoh berikut.

java -cp "kafka_2.12-2.8.1/libs/*:kafka_2.12-2.8.1/libs/aws-msk-iam-auth-2.3.0-all.jar" org.apache.kafka.tools.ConsoleProducer —broker-list $BS —producer.config client.properties —topic msk-serverless-tutorial

Langkah Selanjutnya

Menghapus sumber daya yang Anda buat untuk MSK Serverless