Langkah 3: Buat mesin klien dan topik Apache Kafka

Pada langkah ini Anda membuat instans Amazon EC2 untuk digunakan sebagai instans klien Apache Kafka. Anda kemudian menggunakan instance ini untuk membuat topik di cluster.

Untuk membuat mesin klien

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

2. Pilih Luncurkan Instans.

3. Masukkan Nama untuk mesin klien Anda, sepertimkc-tutorial-client.

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

5. Pilih jenis instans t2.xlarge.

6. Di bawah Key pair (login), pilih Create a new key pair. Masukkan mkc-tutorial-key-pair nama pasangan Kunci, lalu pilih Unduh Pasangan Kunci. Alternatifnya, Anda dapat menggunakan pasangan kunci yang sudah ada.

7. Pilih Luncurkan instans.

8. Pilih Lihat Instans. Kemudian, di kolom Grup Keamanan, pilih grup keamanan yang terkait dengan instans baru Anda. Salin ID grup keamanan, dan simpan untuk nanti.

Untuk memungkinkan klien yang baru dibuat mengirim data ke cluster

1. Buka konsol Amazon VPC di https://console.aws.amazon.com/vpc/.

2. Di panel kiri, di bawah KEAMANAN, pilih Grup Keamanan. Di kolom ID grup Keamanan, cari grup keamanan klaster. Anda menyimpan ID grup keamanan ini saat Anda membuat klaster diLangkah 1: Siapkan sumber daya yang dibutuhkan. Pilih grup keamanan ini dengan memilih kotak di sebelah kiri barisnya. Pastikan tidak ada grup keamanan lain yang dipilih secara bersamaan.

3. Di bagian bawah layar, pilih tab Aturan masuk.

4. Pilih Edit aturan masuk.

5. Di kiri bawah layar, pilih Tambahkan aturan.

6. Dalam aturan baru, pilih Semua lalu lintas di kolom Jenis. Di bidang di sebelah kanan kolom Sumber, masukkan ID grup keamanan mesin klien. Ini adalah ID grup keamanan yang Anda simpan setelah Anda membuat mesin klien.

7. Pilih Simpan aturan. Cluster MSK Anda sekarang akan menerima semua lalu lintas dari klien yang Anda buat dalam prosedur sebelumnya.

Cara membuat topik

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

2. Dalam tabel contoh pilihmkc-tutorial-client.

3. Di dekat bagian atas layar, pilih Connect, lalu ikuti petunjuk untuk terhubung ke instance.

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

   sudo yum install java-1.8.0

5. Jalankan perintah berikut untuk mengunduh Apache Kafka.

   wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz

   catatan

   Jika Anda ingin menggunakan situs mirror 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.12-2.2.1.tgz

7. Buka direktori kafka_2.12-2.2.1.

8. Buka konsol Amazon MSK di https://console.aws.amazon.com/msk/home?region=us-east-1#/home/.

9. Di panel kiri pilih Cluster, lalu pilih namanya. mkc-tutorial-cluster

10. Pilih Lihat informasi klien.

11. Salin string koneksi Plaintext.

12. Pilih Selesai.

13. Jalankan perintah berikut pada instance klien (mkc-tutorial-client), ganti bootstrapServerStringdengan nilai yang Anda simpan saat melihat informasi klien klaster.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server bootstrapServerString --replication-factor 2 --partitions 1 --topic mkc-tutorial-topic

    Jika perintah berhasil, Anda melihat pesan berikut: Created topic mkc-tutorial-topic.

Langkah Selanjutnya

Langkah 4: Buat konektor