Kafka Manager adalah alat manajemen kluster yang dirancang untuk Kafka. Alat ini menyediakan antarmuka web untuk mengelola kluster Dataflow Kafka dengan mudah. Topik ini menjelaskan cara mengakses antarmuka web Kafka Manager dan menambahkan kluster ke dalamnya.
Prasyarat
Sebuah kluster Dataflow telah dibuat di konsol E-MapReduce (EMR) dengan Kafka dipilih saat pembuatan kluster. Untuk informasi lebih lanjut, lihat Buat kluster.
Jika Kafka dipilih untuk kluster Dataflow, Kafka Manager akan diinstal secara otomatis, dan fitur autentikasi Kafka Manager diaktifkan secara default.
Peringatan
Saat menggunakan Kafka Manager untuk menetapkan ulang partisi, versi saat ini tidak mendukung pembatasan kecepatan (throttling). Jika Anda ingin mengaktifkan throttling, jalankan perintah kafka-configs.sh untuk mengonfigurasi parameter terkait throttling. Untuk informasi lebih lanjut, lihat Batasi lalu lintas operasi dan pemeliharaan broker Kafka.
Prosedur
Akses antarmuka web Kafka Manager melalui mode SSH. Untuk informasi lebih lanjut, lihat Buat terowongan SSH untuk mengakses antarmuka web komponen sumber terbuka.
nullDisarankan untuk mengubah kata sandi jika ini pertama kalinya Anda menggunakan Kafka Manager.
Untuk mencegah port 8085 terpapar, disarankan untuk mengakses antarmuka web Kafka Manager melalui mode SSH. Jika Anda ingin mengakses antarmuka web dengan mengunjungi http://localhost:8085, konfigurasikan daftar putih alamat IP untuk mencegah kebocoran data.
Di halaman login, masukkan nama pengguna dan kata sandi yang dikonfigurasi untuk Kafka Manager.
Ikuti langkah-langkah berikut untuk mendapatkan nama pengguna, kata sandi, dan alamat ZooKeeper:
Masuk ke konsol EMR. Di panel navigasi sebelah kiri, klik EMR pada ECS.
Di bilah navigasi atas, pilih wilayah tempat kluster Anda berada dan pilih grup sumber daya sesuai kebutuhan bisnis Anda.
Di halaman EMR pada ECS, temukan kluster yang diinginkan dan klik Services di kolom Tindakan.
Dapatkan informasi yang diperlukan.
Nama pengguna dan kata sandi
Di tab Services, temukan Kafka Manager dan klik Configure.
Di tab Configure, lihat nilai dari parameter berikut:
kafka.manager.authentication.username: nama pengguna untuk mengakses antarmuka web Kafka Manager.
kafka.manager.authentication.password: kata sandi untuk mengakses antarmuka web Kafka Manager.
Alamat ZooKeeper
Di tab Services, temukan Kafka dan klik Configure.
Di tab Configure, klik tab server.properties dan lihat nilai parameter zookeeper.connect.
Di antarmuka web Kafka Manager, pilih .
Di halaman Add Cluster, konfigurasikan parameter yang dijelaskan dalam tabel berikut dan klik Save.

Parameter
Deskripsi
Cluster Name
Nama kluster Dataflow.
Cluster Zookeeper Hosts
Alamat ZooKeeper.
Masukkan nilai parameter zookeeper.connect yang diperoleh di Langkah 2 di bidang ini.
Kafka Version
Versi Kafka yang diterapkan di kluster Dataflow.
nullKafka Manager mungkin tidak mendukung kluster Dataflow yang berisi Kafka versi terbaru. Anda dapat memilih versi terbaru yang didukung oleh Kafka Manager.
Enable JMX Polling (Set JMX_PORT env variable before starting kafka server)
Menentukan apakah akan mengaktifkan fitur Java Management Extensions (JMX).
Dalam contoh ini, fitur JMX diaktifkan.
brokerViewThreadPoolSize
Ukuran thread pool untuk mendapatkan data.
nullAtur parameter ini ke nilai yang lebih besar dari 2.
Setelah menambahkan kluster Dataflow, Anda dapat menggunakan fitur umum Kafka.
