View a markdown version of this page

Buat mesin klien dan topik Apache Kafka - 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 dan topik Apache Kafka

Pada langkah ini Anda membuat instance Amazon EC2 untuk digunakan sebagai instance klien Apache Kafka. Anda kemudian menggunakan instance ini untuk membuat topik pada 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. Biarkan Amazon Linux 2 AMI (HVM) - Kernel 5.10, Jenis Volume SSD dipilih untuk jenis Amazon Machine Image (AMI).

  5. Pilih jenis instance t2.xlarge.

  6. Di bawah Pasangan kunci (login), pilih Buat pasangan kunci baru. 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 instance baru Anda. Salin ID grup keamanan, dan simpan untuk nanti.

Untuk mengizinkan 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, temukan grup keamanan cluster. Anda menyimpan ID grup keamanan ini saat membuat cluster diMenyiapkan sumber daya yang diperlukan untuk MSK Connect. 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. Pilih Tambahkan aturan.

  6. Di 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. Pilih Connect, lalu ikuti petunjuk untuk menyambung 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 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.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 wilayah = us-east-1#/rumah/.

  9. Di panel kiri pilih Clu sters, lalu pilih namamkc-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 bootstrapServerString dengan nilai yang Anda simpan saat Anda melihat informasi klien cluster.

    <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

Buat konektor