Langkah 4: Buat topik

Pada langkah Memulai Menggunakan Amazon MSK ini, Anda menginstal pustaka dan alat klien Apache Kafka di mesin klien, dan kemudian Anda membuat topik.

Awas

Nomor versi Apache Kafka yang digunakan dalam tutorial ini adalah contoh saja. Kami menyarankan Anda menggunakan versi klien yang sama dengan versi cluster MSK Anda. Versi klien yang lebih lama mungkin kehilangan fitur tertentu dan perbaikan bug penting.

Untuk menemukan versi kluster MSK Anda

1. Pergi ke https://eu-west-2.console.aws.amazon.com/msk/

2. Pilih cluster MSK.

3. Perhatikan versi Apache Kafka yang digunakan pada cluster.

4. Ganti contoh nomor versi Amazon MSK dalam tutorial ini dengan versi yang diperoleh pada Langkah 3.

Untuk membuat topik di mesin klien

1. Buka konsol Amazon EC2 di https://console.aws.amazon.com/ec2/.

2. Di panel navigasi, pilih Instans. Kemudian pilih kotak centang di samping nama mesin klien yang Anda buatLangkah 3: Buat mesin klien.

3. Pilih Actions, lalu pilih Connect. Ikuti petunjuk di konsol untuk terhubung ke mesin klien Anda.

4. Instal Java pada mesin klien dengan menjalankan perintah berikut:

   sudo yum -y install java-11

5. Jalankan perintah berikut untuk mengunduh Apache Kafka.

   wget https://archive.apache.org/dist/kafka/{YOUR MSK VERSION}/kafka_2.13-{YOUR MSK VERSION}.tgz

   catatan

   Jika Anda ingin menggunakan situs cermin selain yang digunakan dalam perintah ini, Anda dapat memilih yang berbeda di situs web Apache.

6. Jalankan perintah berikut di direktori tempat Anda mengunduh file TAR pada langkah sebelumnya.

   tar -xzf kafka_2.13-{YOUR MSK VERSION}.tgz

7. Buka kafka_2.13-{YOUR MSK VERSION}/libs direktori, lalu jalankan perintah berikut untuk mengunduh file Amazon MSK IAM JAR. Amazon MSK IAM JAR memungkinkan mesin klien mengakses cluster.

   wget https://github.com/aws/aws-msk-iam-auth/releases/download/v1.1.1/aws-msk-iam-auth-1.1.1-all.jar

8. Pergi ke kafka_2.13-{YOUR MSK VERSION}/bin direktori. Salin pengaturan properti berikut dan tempel ke file baru. Beri nama file client.properties dan simpan.

   security.protocol=SASL_SSL
   sasl.mechanism=AWS_MSK_IAM
   sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
   sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler

9. Buka konsol MSK Amazon dihttps://console.aws.amazon.com/msk/.

10. Tunggu status klaster Anda menjadi Aktif. Ini mungkin memakan waktu beberapa menit. Setelah status menjadi Aktif, pilih nama cluster. Ini membawa Anda ke halaman yang berisi ringkasan cluster.

11. Pilih Lihat informasi klien.

12. Salin string koneksi untuk titik akhir pribadi.

    Anda akan mendapatkan tiga titik akhir untuk masing-masing broker. Anda hanya perlu satu titik akhir broker untuk langkah berikut.

13. Jalankan perintah berikut, ganti BootstrapServerString dengan salah satu endpoint broker yang Anda peroleh pada langkah sebelumnya.

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

    Jika perintah berhasil, Anda melihat pesan berikut: Created topic MSKTutorialTopic.

Langkah Selanjutnya

Langkah 5: Menghasilkan dan mengkonsumsi data