Bagikan melalui

Pelajari cara mengonfigurasi Apache Kafka di Microsoft Azure HDInsight untuk membuat topik secara otomatis

Secara default, Apache Kafka di Microsoft Azure HDInsight tidak mengaktifkan pembuatan topik otomatis. Anda dapat mengaktifkan pembuatan topik otomatis untuk kluster yang ada menggunakan Apache Ambari. Anda juga dapat mengaktifkan pembuatan topik otomatis saat membuat kluster Kafka baru menggunakan templat Azure Resource Manager.

Apache Ambari Web UI

Untuk mengaktifkan pembuatan topik otomatis pada kluster yang ada melalui Ambari Web UI, gunakan langkah-langkah berikut:

  1. Dari portal Azure, pilih kluster Kafka Anda.

  2. Dari dasbor Klaster, pilih Ambari home.

    Gambar portal dengan dasbor kluster yang dipilih.

    Ketika diminta, lakukan otentikasi menggunakan kredensial login (admin) pada kluster. Sebagai gantinya, Anda dapat terhubung ke Ambari langsung dari https://CLUSTERNAME.azurehdinsight.net/ mana CLUSTERNAME adalah nama kluster Kafka Anda.

  3. Pilih layanan Kafka dari daftar di sebelah kiri halaman.

    Tab daftar layanan Apache Ambari.

  4. Pilih Konfigurasi di tengah halaman.

    Tab konfigurasi layanan Apache Ambari.

  5. Di bidang Filter, masukkan nilai dari auto.create.

    Filter pencarian Apache Ambari.

    Pengaturan ini memfilter daftar properti dan menampilkan pengaturan auto.create.topics.enable.

  6. Ubah nilai auto.create.topics.enable menjadi true, lalu pilih Simpan. Tambahkan catatan, lalu pilih Simpan lagi.

    Gambar entri auto.create.topics.enable.

  7. Pilih layanan Kafka, pilih Mulai ulang, lalu pilih Mulai ulang semua yang terdampak. Saat diminta, pilih Konfirmasi Mulai Ulang Semua.

    'Apache Ambari mulai ulang semua yang terpengaruh'.

Catatan

Anda juga dapat menetapkan nilai Ambari melalui Ambari REST API. Ini umumnya lebih sulit, karena Anda harus melakukan beberapa panggilan REST untuk mengambil konfigurasi saat ini, memodifikasinya, dll. Untuk informasi selengkapnya, lihat kluster HDInsight Terkelola menggunakan dokumen APACHE Ambari REST API .

Templat Pengelola Sumber Daya

Saat membuat kluster Kafka menggunakan templat Azure Resource Manager, Anda bisa langsung mengaturnya dengan menambahkannya dalam auto.create.topics.enablekafka-broker. Cuplikan JSON berikut menunjukkan cara menetapkan nilai ini ke true :

"clusterDefinition": {
    "kind": "kafka",
    "configurations": {
        "gateway": {
            "restAuthCredential.isEnabled": true,
            "restAuthCredential.username": "[parameters('clusterLoginUserName')]",
            "restAuthCredential.password": "[parameters('clusterLoginPassword')]"
        },
        "kafka-broker": {
            "auto.create.topics.enable": "true"
        }
    }
}

Langkah berikutnya

Dalam dokumen ini, Anda belajar cara mengaktifkan pembuatan topik otomatis untuk Apache Kafka di Microsoft Azure HDInsight. Lihat tautan berikut ini untuk mempelajari lebih lanjut cara bekerja dengan Kafka: