View a markdown version of this page

Menghasilkan dan mengkonsumsi pesan menggunakan otentikasi - 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 pesan menggunakan otentikasi

Proses ini menjelaskan cara menghasilkan dan mengkonsumsi pesan menggunakan otentikasi.

  1. Jalankan perintah berikut untuk membuat topik. File bernama client.properties adalah yang Anda buat dalam prosedur sebelumnya.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server BootstrapBroker-String --replication-factor 3 --partitions 1 --topic ExampleTopic --command-config client.properties

  2. Jalankan perintah berikut untuk memulai produsen konsol. File bernama client.properties adalah yang Anda buat dalam prosedur sebelumnya.

    <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --bootstrap-server BootstrapBroker-String --topic ExampleTopic --producer.config client.properties

  3. Di jendela perintah baru pada mesin klien Anda, jalankan perintah berikut untuk memulai konsumen konsol.

    <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapBroker-String --topic ExampleTopic --consumer.config client.properties

  4. Ketik pesan di jendela produsen dan saksikan mereka muncul di jendela konsumen.