View a markdown version of this page

Buat mesin klien untuk mengakses cluster Tanpa Server MSK - 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.

Buat mesin klien untuk mengakses cluster Tanpa Server MSK

Pada langkah tersebut, Anda melakukan dua tugas. Tugas pertama adalah membuat instance Amazon EC2 untuk digunakan sebagai mesin klien Apache Kafka. Tugas kedua adalah menginstal alat Java dan Apache Kafka pada mesin.

Untuk membuat mesin klien

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

  2. Pilih Luncurkan instans.

  3. Masukkan Nama deskriptif untuk mesin klien Anda, sepertimsk-serverless-tutorial-client.

  4. Biarkan Amazon Linux 2 AMI (HVM) - Kernel 5.10, Jenis Volume SSD dipilih untuk jenis Amazon Machine Image (AMI).

  5. Biarkan jenis instance t2.micro dipilih.

  6. Di bawah Pasangan kunci (login), pilih Buat pasangan kunci baru. Masukkan MSKServerlessKeyPair untuk nama pasangan kunci. Kemudian pilih Unduh Pasangan Kunci. Alternatifnya, Anda dapat menggunakan pasangan kunci yang sudah ada.

  7. Untuk Pengaturan jaringan, pilih Edit.

  8. Di bawah VPC, masukkan ID cloud pribadi virtual (VPC) untuk cluster tanpa server Anda. Ini adalah VPC berdasarkan layanan Amazon VPC yang ID-nya Anda simpan setelah membuat cluster.

  9. Untuk Subnet, pilih subnet yang ID-nya Anda simpan setelah Anda membuat cluster.

  10. Untuk Firewall (grup keamanan), pilih grup keamanan yang terkait dengan cluster. Nilai ini berfungsi jika grup keamanan tersebut memiliki aturan masuk yang memungkinkan lalu lintas dari grup keamanan ke dirinya sendiri. Dengan aturan seperti itu, anggota kelompok keamanan yang sama dapat berkomunikasi satu sama lain. Untuk informasi selengkapnya, lihat Aturan grup keamanan di Panduan Pengembang Amazon VPC.

  11. Perluas bagian Detail lanjutan dan pilih peran IAM yang Anda buat. Membuat peran IAM untuk topik pada cluster MSK Serverless

  12. Pilih Luncurkan.

  13. Di panel navigasi kiri, pilih Instans. Kemudian pilih kotak centang di baris yang mewakili instans Amazon EC2 yang baru dibuat. Dari titik ini ke depan, kita menyebut instance ini mesin klien.

  14. Pilih Connect dan ikuti petunjuk untuk menyambung ke mesin klien.

Untuk mengatur alat klien Apache Kafka pada mesin klien

  1. Untuk menginstal Java, jalankan perintah berikut pada mesin klien:

    sudo yum -y install java-11

  2. Untuk mendapatkan alat Apache Kafka yang kita butuhkan untuk membuat topik dan mengirim data, jalankan perintah berikut:

    wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
    tar -xzf kafka_2.12-2.8.1.tgz
    catatan

    Setelah mengekstrak arsip Kafka, pastikan bahwa skrip di bin direktori memiliki izin eksekusi yang tepat. Untuk melakukan ini, jalankan perintah berikut.

    chmod +x kafka_2.12-2.8.1/bin/*.sh

  3. Buka kafka_2.12-2.8.1/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/v2.3.0/aws-msk-iam-auth-2.3.0-all.jar

    Dengan menggunakan perintah ini, Anda juga dapat mengunduh versi lain atau yang lebih baru dari file Amazon MSK IAM JAR.

  4. Pergi ke kafka_2.12-2.8.1/bin direktori. Salin pengaturan properti berikut dan tempelkan 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

Langkah Selanjutnya

Buat topik Apache Kafka