Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Mulai menggunakan Amazon MSK
Tutorial ini menunjukkan contoh bagaimana Anda dapat membuat cluster MSK, memproduksi dan mengkonsumsi data, dan memantau kesehatan cluster Anda menggunakan metrik. Contoh ini tidak mewakili semua opsi yang dapat Anda pilih saat Anda membuat klaster MSK. Di berbagai bagian tutorial ini, kami memilih opsi default untuk kesederhanaan. Ini tidak berarti bahwa mereka adalah satu-satunya opsi yang berfungsi untuk menyiapkan cluster MSK atau instance klien.
**Topics**
+ [Langkah 1: Buat klaster MSK Provisioned](create-cluster.md)
+ [Langkah 2: Buat peran IAM yang memberikan akses untuk membuat topik di klaster MSK Amazon](create-client-iam-role.md)
+ [Langkah 3: Buat mesin klien](create-client-machine.md)
+ [Langkah 4: Buat topik di cluster MSK Amazon](create-topic.md)
+ [Langkah 5: Menghasilkan dan Mengkonsumsi Data](produce-consume.md)
+ [Langkah 6: Gunakan Amazon CloudWatch untuk melihat metrik MSK Amazon](view-metrics.md)
+ [Langkah 7: Hapus AWS sumber daya yang dibuat untuk tutorial ini](delete-cluster.md)
# Langkah 1: Buat klaster MSK Provisioned
Pada langkah [Memulai Menggunakan Amazon MSK ini, Anda membuat klaster Amazon MSK](getting-started.md) Provisioned. Anda menggunakan opsi **Quick create** di Konsol Manajemen AWS untuk membuat cluster ini.
**Untuk membuat cluster MSK Amazon menggunakan Konsol Manajemen AWS**Buat cluster menggunakan Konsol Manajemen AWS
1. Masuk ke Konsol Manajemen AWS, dan buka konsol MSK Amazon di [https://console.aws.amazon.com/msk/rumah? region=us-east-1\$1/home/](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/).
1. Pilih **Buat klaster**.
1. Untuk **metode Creation**, biarkan opsi **Quick create** dipilih. Opsi **Quick create** memungkinkan Anda membuat cluster dengan pengaturan default.
1. Untuk **nama Cluster**, masukkan nama deskriptif untuk klaster Anda. Misalnya, **MSKTutorialCluster**.
1. Untuk **properti cluster Umum**, lakukan hal berikut:
1. Untuk **tipe Cluster**, pilih **Provisioned**.
1. Pilih **versi Apache Kafka** untuk dijalankan di broker. Pilih **Lihat kompatibilitas versi** untuk melihat tabel perbandingan.
1. Untuk **jenis Broker**, pilih pialang Standar atau Ekspres.
1. Pilih **ukuran Broker**.
1. Dari tabel di bawah **Semua pengaturan cluster**, salin nilai pengaturan berikut dan simpan karena Anda membutuhkannya nanti dalam tutorial ini:
+ VPC
+ Subnet
+ Grup keamanan yang terkait dengan VPC
1. Pilih **Buat klaster**.
1. Periksa **Status** cluster pada halaman **ringkasan Cluster**. Status berubah dari **Creating** menjadi **Active** karena Amazon MSK menyediakan klaster. Ketika statusnya **Aktif**, Anda dapat terhubung ke cluster. Untuk informasi selengkapnya tentang status klaster, lihat[Memahami status cluster MSK Provisioned](msk-cluster-states.md).
**Langkah Selanjutnya**
[Langkah 2: Buat peran IAM yang memberikan akses untuk membuat topik di klaster MSK Amazon](create-client-iam-role.md)
# Langkah 2: Buat peran IAM yang memberikan akses untuk membuat topik di klaster MSK Amazon
Pada langkah ini, Anda melakukan dua tugas. Tugas pertama adalah membuat kebijakan IAM yang memberikan akses untuk membuat topik di cluster dan mengirim data ke topik tersebut. Tugas kedua adalah membuat peran IAM dan mengaitkan kebijakan ini dengannya. Pada langkah selanjutnya, Anda membuat mesin klien yang mengasumsikan peran ini dan menggunakannya untuk membuat topik di klaster dan mengirim data ke topik tersebut.
**Untuk membuat kebijakan IAM yang memungkinkan untuk membuat topik dan menulis kepada mereka**Buat kebijakan IAM
1. Buka konsol IAM di [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/).
1. Pada panel navigasi, pilih **Kebijakan**.
1. Pilih **Buat kebijakan**.
1. Di **Editor kebijakan**, pilih **JSON**, lalu ganti JSON di jendela editor dengan JSON berikut.
Dalam contoh berikut, ganti yang berikut ini:
+ *region*dengan kode Wilayah AWS tempat Anda membuat cluster Anda.
+ Contoh ID akun,*123456789012*, dengan Akun AWS ID Anda.
+ *MSKTutorialCluster*dan*MSKTutorialCluster*/*7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14*, dengan nama cluster Anda dan ID-nya.
------
#### [ JSON ]
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": [
"kafka-cluster:Connect",
"kafka-cluster:AlterCluster",
"kafka-cluster:DescribeCluster"
],
"Resource": [
"arn:aws:kafka:us-east-1:123456789012:cluster/MSKTutorialCluster/7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14"
]
},
{
"Effect": "Allow",
"Action": [
"kafka-cluster:*Topic*",
"kafka-cluster:WriteData",
"kafka-cluster:ReadData"
],
"Resource": [
"arn:aws:kafka:us-east-1:123456789012:topic/MSKTutorialCluster/*"
]
},
{
"Effect": "Allow",
"Action": [
"kafka-cluster:AlterGroup",
"kafka-cluster:DescribeGroup"
],
"Resource": [
"arn:aws:kafka:us-east-1:123456789012:group/MSKTutorialCluster/*"
]
}
]
}
```
------
Untuk petunjuk tentang cara menulis kebijakan aman, lihat[Kontrol akses IAM](iam-access-control.md).
1. Pilih **Berikutnya**.
1. Pada halaman **Review dan create**, lakukan hal berikut:
1. Untuk **nama Kebijakan**, masukkan nama deskriptif, seperti**msk-tutorial-policy**.
1. Di **Izin yang ditentukan dalam kebijakan ini**, tinjau and/or edit izin yang ditentukan dalam kebijakan Anda.
1. (Opsional) Untuk membantu mengidentifikasi, mengatur, atau mencari kebijakan, pilih **Tambahkan tag baru** untuk menambahkan tag sebagai pasangan nilai kunci. Misalnya, tambahkan tag ke kebijakan Anda dengan pasangan nilai kunci dan**Environment**. **Test**
Untuk informasi selengkapnya tentang penggunaan tag, lihat [Tag untuk AWS Identity and Access Management sumber daya](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) di *Panduan Pengguna IAM*.
1. Pilih **Buat kebijakan**.
**Untuk membuat peran IAM dan melampirkan kebijakan padanya**
1. Pada panel navigasi, pilih **Peran**, lalu pilih **Buat peran**.
1. Pada halaman **Pilih entitas tepercaya**, lakukan hal berikut:
1. Untuk **jenis entitas Tepercaya**, pilih **Layanan AWS**.
1. Untuk **Service atau use case**, pilih **EC2**.
1. Di bawah **Kasus penggunaan**, pilih **EC2**.
1. Pilih **Berikutnya**.
1. Pada halaman **Tambahkan izin**, lakukan hal berikut:
1. Di kotak pencarian di bawah **Kebijakan izin**, masukkan nama kebijakan yang sebelumnya Anda buat untuk tutorial ini. Kemudian, pilih kotak di sebelah kiri nama kebijakan.
1. (Opsional) Tetapkan [batas izin](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_boundaries.html). Ini adalah fitur lanjutan yang tersedia untuk peran layanan, tetapi bukan peran tertaut layanan. *Untuk informasi tentang menyetel batas izin, lihat [Membuat peran dan melampirkan kebijakan (konsol)](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_job-functions_create-policies.html) di Panduan Pengguna IAM.*
1. Pilih **Berikutnya**.
1. Pada halaman **Nama, tinjau, dan buat**, lakukan hal berikut:
1. Untuk **nama Peran**, masukkan nama deskriptif, seperti**msk-tutorial-role**.
**penting**
Saat Anda memberi nama peran, perhatikan hal berikut:
Nama peran harus unik di dalam diri Anda Akun AWS, dan tidak dapat dibuat unik berdasarkan kasus.
Misalnya, jangan membuat peran bernama keduanya **PRODROLE** dan**prodrole**. Ketika nama peran digunakan dalam kebijakan atau sebagai bagian dari ARN, nama peran tersebut peka huruf besar/kecil, namun ketika nama peran muncul kepada pelanggan di konsol, seperti selama proses masuk, nama peran tersebut tidak peka huruf besar/kecil.
Anda tidak dapat mengedit nama peran setelah dibuat karena entitas lain mungkin mereferensikan peran tersebut.
1. (Opsional) Untuk **Deskripsi**, masukkan deskripsi untuk peran tersebut.
1. **(Opsional) Untuk mengedit kasus penggunaan dan izin untuk peran, di **Langkah 1: Pilih entitas tepercaya** atau **Langkah 2: Tambahkan bagian izin**, pilih Edit.**
1. (Opsional) Untuk membantu mengidentifikasi, mengatur, atau mencari peran, pilih **Tambahkan tag baru** untuk menambahkan tag sebagai pasangan nilai kunci. Misalnya, tambahkan tag ke peran Anda dengan pasangan kunci-nilai dan**ProductManager**. **John**
Untuk informasi selengkapnya tentang penggunaan tag, lihat [Tag untuk AWS Identity and Access Management sumber daya](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) di *Panduan Pengguna IAM*.
1. Tinjau peran lalu pilih **Buat peran**.
**Langkah Selanjutnya**
[Langkah 3: Buat mesin klien](create-client-machine.md)
# Langkah 3: Buat mesin klien
Pada langkah [Memulai Menggunakan Amazon MSK](getting-started.md) ini, Anda membuat mesin klien. Anda menggunakan mesin klien ini untuk membuat topik yang menghasilkan dan mengkonsumsi data. Untuk mempermudah, Anda akan membuat mesin klien ini di VPC yang terkait dengan cluster MSK sehingga klien dapat dengan mudah terhubung ke cluster.
**Untuk membuat mesin klien**Buat mesin klien
1. Buka konsol Amazon EC2 di. [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/)
1. Dari dasbor konsol Amazon EC2, pilih **Luncurkan instans**.
1. Di bawah **Nama dan tag**, untuk **Nama**, masukkan nama deskriptif untuk mesin klien Anda sehingga Anda dapat dengan mudah melacaknya. Misalnya, **MSKTutorialClient**.
1. Di bawah Gambar **Aplikasi dan OS (Gambar Mesin Amazon)**, untuk **Amazon Machine Image (AMI)**, pilih **Amazon Linux 2 AMI (HVM) - Kernel 5.10, Jenis Volume SSD**.
1. Untuk **tipe Instance**, pertahankan pilihan default **t2.micro**.
1. Di bawah **Key pair (login)**, pilih key pair yang ada atau buat yang baru. Jika Anda tidak memerlukan key pair untuk terhubung ke instans Anda, Anda dapat memilih **Proceed without a key pair (tidak disarankan)**.
Untuk membuat pasangan kunci baru, lakukan hal berikut:
1. Pilih **Create new key pair**.
1. Untuk **nama pasangan kunci**, masukkan**MSKKeyPair**.
1. Untuk **jenis pasangan kunci** dan **format file kunci pribadi**, pertahankan pilihan default.
1. Pilih **Buat pasangan kunci**.
Alternatifnya, Anda dapat menggunakan pasangan kunci yang sudah ada.
1. Gulir ke bawah halaman dan perluas bagian **Detail lanjutan**, lalu lakukan hal berikut:
1. Untuk **profil instans IAM**, pilih peran IAM yang Anda ingin diasumsikan oleh mesin klien.
Jika Anda tidak memiliki peran IAM, lakukan hal berikut:
1. Pilih **Buat profil IAM baru**.
1. Lakukan langkah-langkah yang disebutkan dalam [Langkah 2: Buat peran IAM](create-client-iam-role.md).
1. Pilih **Luncurkan instans**.
1. 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.
1. Buka konsol VPC Amazon di. [https://console.aws.amazon.com/vpc/](https://console.aws.amazon.com/vpc/)
1. Pada panel navigasi, pilih **Grup Keamanan**. Temukan grup keamanan yang ID Anda simpan[Langkah 1: Buat klaster MSK Provisioned](create-cluster.md).
1. Di tab **Aturan Masuk**, pilih **Edit aturan masuk**.
1. Pilih **Tambahkan aturan**.
1. Dalam aturan baru, pilih **Semua lalu lintas** di kolom **Jenis**. Di bidang kedua di kolom **Sumber**, pilih grup keamanan mesin klien Anda. Ini adalah grup yang namanya Anda simpan setelah Anda meluncurkan instance mesin klien.
1. Pilih **Simpan aturan**. Sekarang grup keamanan cluster dapat menerima lalu lintas yang berasal dari grup keamanan mesin klien.
**Langkah Selanjutnya**
[Langkah 4: Buat topik di cluster MSK Amazon](create-topic.md)
# Langkah 4: Buat topik di cluster MSK Amazon
Pada langkah [Memulai Menggunakan Amazon MSK](getting-started.md) ini, Anda dapat membuat topik menggunakan salah satu dari dua pendekatan: menggunakan AWS alat asli dengan CreateTopic API, atau menggunakan alat Apache Kafka pada AdminClient mesin klien.
**Awas**
Saat menggunakan AWS alat dengan CreateTopic API, verifikasi bahwa klaster Anda memenuhi persyaratan. Untuk detailnya, lihat [Persyaratan untuk menggunakan topik APIs](https://docs.aws.amazon.com/msk/latest/developerguide/msk-topic-operations-information.html#topic-operations-requirements).
**Awas**
Saat menggunakan AdminClient pendekatan ini, 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.
**Topics**
+ [Membuat topik menggunakan AWS alat](#create-topic-aws-tools)
+ [Menentukan versi klaster MSK Anda](#find-msk-cluster-version)
+ [Membuat topik di mesin klien](#create-topic-client-machine)
## Membuat topik menggunakan AWS alat
Anda dapat membuat topik di klaster MSK Anda menggunakan AWS alat seperti AWS CLI AWS SDKs,, atau AWS Konsol Manajemen. Pendekatan ini menyediakan cara yang efisien untuk mengelola topik tanpa memerlukan akses langsung ke alat klien Kafka.
Untuk informasi mendetail tentang membuat topik menggunakan AWS alat, lihat [panduan pengembang CreateTopic API](https://docs.aws.amazon.com/msk/latest/developerguide/msk-create-topic.html).
## Menentukan versi klaster MSK Anda
1. Buka konsol MSK Amazon di[https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/).
1. Di bilah navigasi, pilih Wilayah tempat Anda membuat cluster MSK.
1. Pilih cluster MSK.
1. Perhatikan versi Apache Kafka yang digunakan pada cluster.
1. Ganti contoh nomor versi Amazon MSK dalam tutorial ini dengan versi yang diperoleh pada Langkah 3.
## Membuat topik di mesin klien
1. **Connect ke mesin klien Anda.**
1. Buka konsol Amazon EC2 di. [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/)
1. Di panel navigasi, pilih **Instans**. Kemudian, pilih kotak centang di samping nama mesin klien yang Anda buat[Langkah 3: Buat mesin klien](create-client-machine.md).
1. Pilih **Actions**, lalu pilih **Connect**. Ikuti petunjuk di konsol untuk terhubung ke mesin klien Anda.
1. **Instal Java dan atur variabel lingkungan versi Kafka.**
1. Instal Java pada mesin klien dengan menjalankan perintah berikut.
```
sudo yum -y install java-11
```
1. Simpan [versi Kafka](#find-msk-cluster-version) dari cluster MSK Anda dalam variabel lingkungan`KAFKA_VERSION`, seperti yang ditunjukkan pada perintah berikut. Anda akan memerlukan informasi ini di seluruh pengaturan.
```
export KAFKA_VERSION={KAFKA VERSION}
```
Misalnya, jika Anda menggunakan versi 3.6.0, gunakan perintah berikut.
```
export KAFKA_VERSION=3.6.0
```
1. **Unduh dan ekstrak Apache Kafka.**
1. Jalankan perintah berikut untuk mengunduh Apache Kafka.
```
wget https://archive.apache.org/dist/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz
```
**catatan**
Daftar berikut menyajikan beberapa informasi unduhan Kafka alternatif yang dapat Anda gunakan, jika Anda mengalami masalah.
Jika Anda mengalami masalah konektivitas atau ingin menggunakan situs mirror, coba gunakan pemilih cermin Apache, seperti yang ditunjukkan pada perintah berikut.
```
wget https://www.apache.org/dyn/closer.cgi?path=/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz
```
Unduh versi yang sesuai langsung dari situs web [Apache Kafka](https://kafka.apache.org/downloads).
1. Jalankan perintah berikut di direktori tempat Anda mengunduh file TAR pada langkah sebelumnya.
```
tar -xzf kafka_2.13-$KAFKA_VERSION.tgz
```
1. Simpan path lengkap ke direktori yang baru dibuat di dalam variabel `KAFKA_ROOT` lingkungan.
```
export KAFKA_ROOT=$(pwd)/kafka_2.13-$KAFKA_VERSION
```
1. **Siapkan otentikasi untuk klaster MSK Anda.**
1. [Temukan versi terbaru dari pustaka](https://github.com/aws/aws-msk-iam-auth/releases/latest) klien Amazon MSK IAM. Pustaka ini memungkinkan mesin klien Anda untuk mengakses kluster MSK menggunakan otentikasi IAM.
1. Dengan menggunakan perintah berikut, navigasikan ke `$KAFKA_ROOT/libs` direktori dan unduh Amazon MSK IAM JAR terkait yang Anda temukan di langkah sebelumnya. Pastikan untuk mengganti *\$1LATEST VERSION\$1* dengan nomor versi aktual yang Anda unduh.
```
cd $KAFKA_ROOT/libs
```
```
wget https://github.com/aws/aws-msk-iam-auth/releases/latest/download/aws-msk-iam-auth-{LATEST VERSION}-all.jar
```
**catatan**
Sebelum menjalankan perintah Kafka yang berinteraksi dengan kluster MSK Anda, Anda mungkin perlu menambahkan file Amazon MSK IAM JAR ke classpath Java Anda. Mengatur variabel `CLASSPATH` lingkungan, seperti yang ditunjukkan pada contoh berikut.
```
export CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar
```
Ini mengatur `CLASSPATH` untuk seluruh sesi Anda, membuat JAR tersedia untuk semua perintah Kafka berikutnya.
1. Pergi ke `$KAFKA_ROOT/config` direktori untuk membuat file konfigurasi klien.
```
cd $KAFKA_ROOT/config
```
1. Salin pengaturan properti berikut dan tempel ke file baru. Simpan file sebagai **client.properties**.
```
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
```
1. **(Opsional) Sesuaikan ukuran tumpukan Java untuk alat Kafka.**
Jika Anda mengalami masalah terkait memori atau Anda bekerja dengan sejumlah besar topik atau partisi, Anda dapat menyesuaikan ukuran tumpukan Java. Untuk melakukan ini, atur variabel `KAFKA_HEAP_OPTS` lingkungan sebelum menjalankan perintah Kafka.
Contoh berikut menetapkan ukuran heap maksimum dan awal menjadi 512 megabyte. Sesuaikan nilai-nilai ini sesuai dengan kebutuhan spesifik Anda dan sumber daya sistem yang tersedia.
```
export KAFKA_HEAP_OPTS="-Xmx512M -Xms512M"
```
1. **Dapatkan informasi koneksi cluster Anda.**
1. Buka konsol MSK Amazon di[https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/).
1. 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.
1. Pilih **Lihat informasi klien**.
1. Salin string koneksi untuk titik akhir pribadi.
Anda akan mendapatkan tiga titik akhir untuk masing-masing broker. Simpan salah satu string koneksi ini dalam variabel lingkungan`BOOTSTRAP_SERVER`, seperti yang ditunjukkan pada perintah berikut. Ganti ** dengan nilai sebenarnya dari string koneksi.
```
export BOOTSTRAP_SERVER=
```
1. **Jalankan perintah berikut untuk membuat topik.**
```
$KAFKA_ROOT/bin/kafka-topics.sh --create --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties --replication-factor 3 --partitions 1 --topic MSKTutorialTopic
```
Jika Anda mendapatkan `NoSuchFileException` untuk `client.properties` file tersebut, pastikan bahwa file ini ada di direktori kerja saat ini dalam direktori Kafka bin.
**catatan**
Jika Anda memilih untuk tidak mengatur variabel `CLASSPATH` lingkungan untuk seluruh sesi Anda, Anda dapat mengawali setiap perintah Kafka dengan variabel. `CLASSPATH` Pendekatan ini menerapkan classpath hanya untuk perintah tertentu.
```
CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar \
$KAFKA_ROOT/bin/kafka-topics.sh --create \
--bootstrap-server $BOOTSTRAP_SERVER \
--command-config $KAFKA_ROOT/config/client.properties \
--replication-factor 3 \
--partitions 1 \
--topic MSKTutorialTopic
```
1. **(Opsional) Verifikasi bahwa topik telah berhasil dibuat.**
1. Jika perintah berhasil, Anda akan melihat pesan berikut: `Created topic MSKTutorialTopic.`
1. Buat daftar semua topik untuk mengonfirmasi bahwa topik Anda ada.
```
$KAFKA_ROOT/bin/kafka-topics.sh --list --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties
```
Jika perintah tidak berhasil atau Anda mengalami kesalahan, lihat [Memecahkan masalah klaster MSK Amazon Anda](troubleshooting.md) untuk informasi pemecahan masalah.
1. **(Opsional) Hapus variabel lingkungan yang Anda gunakan dalam tutorial ini.**
Jika Anda ingin menyimpan variabel lingkungan Anda untuk langkah selanjutnya dalam tutorial ini, lewati langkah ini. Jika tidak, Anda dapat menghapus variabel ini, seperti yang ditunjukkan pada contoh berikut.
```
unset KAFKA_VERSION KAFKA_ROOT BOOTSTRAP_SERVER CLASSPATH KAFKA_HEAP_OPTS
```
**Langkah Selanjutnya**
[Langkah 5: Menghasilkan dan Mengkonsumsi Data](produce-consume.md)
# Langkah 5: Menghasilkan dan Mengkonsumsi Data
Pada langkah [Memulai Menggunakan Amazon MSK](getting-started.md) ini, Anda memproduksi dan mengkonsumsi data.
**Untuk menghasilkan dan mengkonsumsi pesan**Menghasilkan dan mengkonsumsi pesan
1. Jalankan perintah berikut untuk memulai produsen konsol.
```
$KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic
```
1. Masukkan pesan apa pun yang Anda inginkan, dan tekan **Enter**. Ulangi langkah ini dua atau tiga kali. Setiap kali Anda memasukkan baris dan tekan **Enter**, baris itu dikirim ke cluster Apache Kafka Anda sebagai pesan terpisah.
1. Biarkan koneksi ke mesin klien tetap terbuka, dan kemudian buka koneksi kedua yang terpisah ke mesin itu di jendela baru. Karena ini adalah sesi baru, atur variabel `KAFKA_ROOT` dan `BOOTSTRAP_SERVER` lingkungan lagi. Untuk informasi tentang cara mengatur variabel lingkungan ini, lihat[Membuat topik di mesin klien](create-topic.md#create-topic-client-machine).
1. Jalankan perintah berikut dengan string koneksi kedua Anda ke mesin klien untuk membuat konsumen konsol.
```
$KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning
```
Anda harus mulai melihat pesan yang Anda masukkan sebelumnya ketika Anda menggunakan perintah produser konsol.
1. Masukkan lebih banyak pesan di jendela produser, dan saksikan mereka muncul di jendela konsumen.
**Langkah Selanjutnya**
[Langkah 6: Gunakan Amazon CloudWatch untuk melihat metrik MSK Amazon](view-metrics.md)
# Langkah 6: Gunakan Amazon CloudWatch untuk melihat metrik MSK Amazon
Pada langkah [Memulai Menggunakan Amazon MSK](getting-started.md) ini, Anda melihat metrik MSK Amazon di Amazon. CloudWatch
**Untuk melihat metrik MSK Amazon di CloudWatch**Lihat metrik di CloudWatch
1. Buka CloudWatch konsol di [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/).
1. Pada panel navigasi, silakan pilih **Metrik**.
1. Pilih tab **Semua metrik**, lalu pilih **AWS/Kafka**.
1. Untuk melihat metrik tingkat broker, pilih **ID Broker**, Nama Cluster. **Untuk metrik tingkat cluster, pilih Nama Cluster.**
1. (Opsional) Di panel grafik, pilih statistik dan periode waktu, lalu buat CloudWatch alarm menggunakan pengaturan ini.
**Langkah Selanjutnya**
[Langkah 7: Hapus AWS sumber daya yang dibuat untuk tutorial ini](delete-cluster.md)
# Langkah 7: Hapus AWS sumber daya yang dibuat untuk tutorial ini
Pada langkah terakhir [Memulai Menggunakan Amazon MSK](getting-started.md), Anda menghapus cluster MSK dan mesin klien yang Anda buat untuk tutorial ini.
**Untuk menghapus sumber daya menggunakan Konsol Manajemen AWS**Hapus sumber daya menggunakan Konsol Manajemen AWS
1. Buka konsol MSK Amazon di[https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/).
1. Pilih nama cluster Anda. Misalnya, **MSKTutorialCluster**.
1. Pilih **Tindakan**, lalu pilih **Hapus**.
1. Buka konsol Amazon EC2 di. [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/)
1. Pilih contoh yang Anda buat untuk mesin klien Anda, misalnya,**MSKTutorialClient**.
1. Pilih **status Instance**, lalu pilih **Terminate instance**.
**Untuk menghapus kebijakan IAM**Hapus kebijakan dan peran IAM
1. Buka konsol IAM di [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/).
1. Pada panel navigasi, pilih **Peran**.
1. Di kotak pencarian, masukkan nama peran IAM yang Anda buat untuk tutorial ini.
1. Pilih perannya. Kemudian pilih **Hapus peran**, dan konfirmasikan penghapusan.
1. Pada panel navigasi, pilih **Kebijakan**.
1. Di kotak pencarian, masukkan nama kebijakan yang Anda buat untuk tutorial ini.
1. Pilih kebijakan untuk membuka halaman ringkasannya. Pada halaman **Ringkasan** kebijakan, pilih **Hapus kebijakan**.
1. Pilih **Hapus**.