全部产品
Search
文档中心

E-MapReduce:Kafka Manager

更新时间:Jun 24, 2025

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.

null

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

  1. Akses antarmuka web Kafka Manager melalui mode SSH. Untuk informasi lebih lanjut, lihat Buat terowongan SSH untuk mengakses antarmuka web komponen sumber terbuka.

    null
    • Disarankan 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.

  2. 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:

    1. Masuk ke konsol EMR. Di panel navigasi sebelah kiri, klik EMR pada ECS.

    2. Di bilah navigasi atas, pilih wilayah tempat kluster Anda berada dan pilih grup sumber daya sesuai kebutuhan bisnis Anda.

    3. Di halaman EMR pada ECS, temukan kluster yang diinginkan dan klik Services di kolom Tindakan.

    4. Dapatkan informasi yang diperlukan.

      • Nama pengguna dan kata sandi

        1. Di tab Services, temukan Kafka Manager dan klik Configure.

        2. 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

        1. Di tab Services, temukan Kafka dan klik Configure.

        2. Di tab Configure, klik tab server.properties dan lihat nilai parameter zookeeper.connect.

  3. Di antarmuka web Kafka Manager, pilih Cluster > Add Cluster.

  4. Di halaman Add Cluster, konfigurasikan parameter yang dijelaskan dalam tabel berikut dan klik Save.

    Add Kafka

    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.

    null

    Kafka 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.

    null

    Atur parameter ini ke nilai yang lebih besar dari 2.

    Setelah menambahkan kluster Dataflow, Anda dapat menggunakan fitur umum Kafka.Kafka