Langkah 4: Buat topik di MSK cluster Amazon - 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.

Langkah 4: Buat topik di MSK cluster Amazon

Pada langkah Memulai Menggunakan Amazon iniMSK, 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 MSK cluster Anda. Versi klien yang lebih lama mungkin kehilangan fitur tertentu dan perbaikan bug penting.

Untuk menemukan versi MSK cluster Anda

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

  2. Pilih MSK cluster.

  3. Perhatikan versi Apache Kafka yang digunakan pada cluster.

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

Untuk membuat topik di mesin klien

  1. Buka EC2 konsol Amazon 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 TAR file 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 MSK IAM JAR file Amazon. Amazon MSK IAM JAR memungkinkan mesin klien untuk 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 MSK konsol 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